Drop redundant name strings from create_task calls in bus + proxy
``BaseObject.create_task`` already auto-names the task based on the
coroutine; the explicit ``f"{self}::..."`` strings duplicated that
default and made the call sites noisier. Remove them.
This commit is contained in:
@@ -139,7 +139,7 @@ class PgmqBus(TaskBus):
|
|||||||
await super().start()
|
await super().start()
|
||||||
self._queue_name = await self._backend.join(self._channel)
|
self._queue_name = await self._backend.join(self._channel)
|
||||||
logger.debug(f"{self}: joined channel via backend; queue='{self._queue_name}'")
|
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)
|
await asyncio.sleep(0)
|
||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
|
|||||||
@@ -71,7 +71,7 @@ class RedisBus(TaskBus):
|
|||||||
pubsub = self._redis.pubsub()
|
pubsub = self._redis.pubsub()
|
||||||
await pubsub.subscribe(self._channel)
|
await pubsub.subscribe(self._channel)
|
||||||
self._pubsub = pubsub
|
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)
|
await asyncio.sleep(0)
|
||||||
|
|
||||||
async def stop(self):
|
async def stop(self):
|
||||||
|
|||||||
@@ -120,7 +120,7 @@ class WebSocketProxyClientTask(BaseTask):
|
|||||||
|
|
||||||
await self._call_event_handler("on_connected", self._ws)
|
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.
|
# Schedule task right away.
|
||||||
await asyncio.sleep(0)
|
await asyncio.sleep(0)
|
||||||
|
|||||||
@@ -107,7 +107,7 @@ class WebSocketProxyServerTask(BaseTask):
|
|||||||
|
|
||||||
await self._call_event_handler("on_client_connected", self._ws)
|
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.
|
# Schedule task right away.
|
||||||
await asyncio.sleep(0)
|
await asyncio.sleep(0)
|
||||||
|
|||||||
Reference in New Issue
Block a user