add id and name properties

src/pipecat/pipeline/task.py

@@ -94,8 +94,8 @@ class PipelineTask(BaseTask):
         params: PipelineParams = PipelineParams(),
         clock: BaseClock = SystemClock(),
     ):
-        self.id: int = obj_id()
+        self._id: int = obj_id()
-        self.name: str = f"{self.__class__.__name__}#{obj_count(self)}"
+        self._name: str = f"{self.__class__.__name__}#{obj_count(self)}"
 
         self._pipeline = pipeline
         self._clock = clock
@@ -123,6 +123,14 @@ class PipelineTask(BaseTask):
 
         self._observer = TaskObserver(params.observers)
 
+    @property
+    def id(self) -> int:
+        return self._id
+
+    @property
+    def name(self) -> str:
+        return self._name
+
     def has_finished(self) -> bool:
         """Indicates whether the tasks has finished. That is, all processors
         have stopped.

src/pipecat/pipeline/task_observer.py

@@ -12,7 +12,7 @@ from attr import dataclass
 from pipecat.frames.frames import Frame
 from pipecat.observers.base_observer import BaseObserver
 from pipecat.processors.frame_processor import FrameDirection, FrameProcessor
-from pipecat.utils.utils import cancel_task, create_task, obj_count
+from pipecat.utils.utils import cancel_task, create_task, obj_count, obj_id
 
 
 @dataclass
@@ -55,9 +55,18 @@ class TaskObserver(BaseObserver):
     """
 
     def __init__(self, observers: List[BaseObserver] = []):
-        self.name: str = f"{self.__class__.__name__}#{obj_count(self)}"
+        self._id: int = obj_id()
+        self._name: str = f"{self.__class__.__name__}#{obj_count(self)}"
         self._proxies: List[Proxy] = self._create_proxies(observers)
 
+    @property
+    def id(self) -> int:
+        return self._id
+
+    @property
+    def name(self) -> str:
+        return self._name
+
     async def stop(self):
         """Stops all proxy observer tasks."""
         for proxy in self._proxies:

src/pipecat/processors/frame_processor.py

@@ -41,8 +41,8 @@ class FrameProcessor:
         loop: asyncio.AbstractEventLoop | None = None,
         **kwargs,
     ):
-        self.id: int = obj_id()
+        self._id: int = obj_id()
-        self.name = name or f"{self.__class__.__name__}#{obj_count(self)}"
+        self._name = name or f"{self.__class__.__name__}#{obj_count(self)}"
         self._parent: "FrameProcessor" | None = None
         self._prev: "FrameProcessor" | None = None
         self._next: "FrameProcessor" | None = None
@@ -83,6 +83,14 @@ class FrameProcessor:
         # the exception to this rule. This create this task.
         self.__create_push_task()
 
+    @property
+    def id(self) -> int:
+        return self._id
+
+    @property
+    def name(self) -> str:
+        return self._name
+
     @property
     def interruptions_allowed(self):
         return self._allow_interruptions

src/pipecat/transports/base_transport.py

@@ -53,13 +53,21 @@ class BaseTransport(ABC):
         output_name: Optional[str] = None,
         loop: Optional[asyncio.AbstractEventLoop] = None,
     ):
-        self.id: int = obj_id()
+        self._id: int = obj_id()
-        self.name = name or f"{self.__class__.__name__}#{obj_count(self)}"
+        self._name = name or f"{self.__class__.__name__}#{obj_count(self)}"
         self._input_name = input_name
         self._output_name = output_name
         self._loop = loop or asyncio.get_running_loop()
         self._event_handlers: dict = {}
 
+    @property
+    def id(self) -> int:
+        return self._id
+
+    @property
+    def name(self) -> str:
+        return self._name
+
     @abstractmethod
     def input(self) -> FrameProcessor:
         raise NotImplementedError