diff --git a/src/pipecat/pipeline/task_observer.py b/src/pipecat/pipeline/task_observer.py index c9816f7d3..ebd806578 100644 --- a/src/pipecat/pipeline/task_observer.py +++ b/src/pipecat/pipeline/task_observer.py @@ -96,7 +96,7 @@ class TaskObserver(BaseObserver): 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 index 099b78aa8..23c0d4a40 100644 --- a/src/pipecat/transports/services/daily.py +++ b/src/pipecat/transports/services/daily.py @@ -223,7 +223,7 @@ class DailyTransportClient(EventHandler): 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