improve create_task names

pipecat-ai · Jan 29, 2025 · 091258f · 091258f
1 parent 2a1408e
commit 091258f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/pipecat/pipeline/task_observer.py b/src/pipecat/pipeline/task_observer.py
@@ -96,7 +96,7 @@ def _create_proxies(self, observers) -> List[Proxy]:
             task = create_task(
                 loop,
                 self._proxy_task_handler(queue, observer),
-                f"{self}::{observer.__class__.__name__}",
+                f"{self}::{observer.__class__.__name__}::_proxy_task_handler",
             )
             proxy = Proxy(queue=queue, task=task, observer=observer)
             proxies.append(proxy)

diff --git a/src/pipecat/transports/services/daily.py b/src/pipecat/transports/services/daily.py
@@ -223,7 +223,7 @@ def __init__(
         self._callback_task = create_task(
             self._loop,
             self._callback_task_handler(),
-            f"{self._transport_name}::DailyTransportClient::callback_task",
+            f"{self._transport_name}::DailyTransportClient::_callback_task_handler",
         )
 
         self._camera: VirtualCameraDevice | None = None