diff --git a/src/pipecat/bus/network/pgmq.py b/src/pipecat/bus/network/pgmq.py
index 8a4c76f3d..2ec369599 100644
--- a/src/pipecat/bus/network/pgmq.py
+++ b/src/pipecat/bus/network/pgmq.py
@@ -139,7 +139,7 @@ class PgmqBus(TaskBus):
         await super().start()
         self._queue_name = await self._backend.join(self._channel)
         logger.debug(f"{self}: joined channel via backend; queue='{self._queue_name}'")
-        self._reader_task = self.create_task(self._reader_loop(), f"{self}::pgmq_reader")
+        self._reader_task = self.create_task(self._reader_loop())
         await asyncio.sleep(0)
 
     async def stop(self):
diff --git a/src/pipecat/bus/network/redis.py b/src/pipecat/bus/network/redis.py
index 55e2d55ea..781660a9d 100644
--- a/src/pipecat/bus/network/redis.py
+++ b/src/pipecat/bus/network/redis.py
@@ -71,7 +71,7 @@ class RedisBus(TaskBus):
         pubsub = self._redis.pubsub()
         await pubsub.subscribe(self._channel)
         self._pubsub = pubsub
-        self._reader_task = self.create_task(self._reader_loop(), f"{self}::redis_reader")
+        self._reader_task = self.create_task(self._reader_loop())
         await asyncio.sleep(0)
 
     async def stop(self):
diff --git a/src/pipecat/tasks/proxy/websocket/client.py b/src/pipecat/tasks/proxy/websocket/client.py
index 8c6d348dc..f9581758c 100644
--- a/src/pipecat/tasks/proxy/websocket/client.py
+++ b/src/pipecat/tasks/proxy/websocket/client.py
@@ -120,7 +120,7 @@ class WebSocketProxyClientTask(BaseTask):
 
         await self._call_event_handler("on_connected", self._ws)
 
-        self._receive_task = self.create_task(self._receive_loop(), f"{self.name}::ws_receive")
+        self._receive_task = self.create_task(self._receive_loop())
 
         # Schedule task right away.
         await asyncio.sleep(0)
diff --git a/src/pipecat/tasks/proxy/websocket/server.py b/src/pipecat/tasks/proxy/websocket/server.py
index 9f6b76fc3..b14b91672 100644
--- a/src/pipecat/tasks/proxy/websocket/server.py
+++ b/src/pipecat/tasks/proxy/websocket/server.py
@@ -107,7 +107,7 @@ class WebSocketProxyServerTask(BaseTask):
 
         await self._call_event_handler("on_client_connected", self._ws)
 
-        self._receive_task = self.create_task(self._receive_loop(), f"{self.name}::ws_receive")
+        self._receive_task = self.create_task(self._receive_loop())
 
         # Schedule task right away.
         await asyncio.sleep(0)