Skip to content

Commit d3a80c5

Browse files
committed
Include appliance/performer name in asyncio task names
Generic task names "Appliance updated by redis" and "Performer updated by redis" made it impossible to identify which entity was involved when asyncio logged task-related messages. Include the specific name. Assisted-By: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent 08337fa commit d3a80c5

File tree

2 files changed

+8
-6
lines changed

2 files changed

+8
-6
lines changed

home/process.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,9 @@ def create_tasks(self, loop, scheduler):
221221

222222
async def monitor(self):
223223
while True:
224-
self._logger.warning("\n\nNew tasks:\n")
224+
self._logger.debug("\n\nNew tasks:\n")
225225
for task in asyncio.all_tasks():
226-
self._logger.warning(task.get_name())
226+
self._logger.debug(task.get_name())
227227
await asyncio.sleep(180)
228228

229229
def run(self, scheduler):

home/redis/gateway/__init__.py

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -102,11 +102,13 @@ async def on_performer_updated_by_process(self, performer, old_state, new_state)
102102
def create_tasks(
103103
self, loop, on_appliance_updated_by_redis, on_performer_updated_by_redis
104104
):
105-
for client in self._appliances.values():
105+
for appliance, client in self._appliances.items():
106106
asyncio.get_event_loop().create_task(
107-
client.run(on_appliance_updated_by_redis), name="Appliance updated by redis"
107+
client.run(on_appliance_updated_by_redis),
108+
name="Appliance {} updated by redis".format(appliance.name),
108109
)
109-
for client in self._performers.values():
110+
for performer, client in self._performers.items():
110111
asyncio.get_event_loop().create_task(
111-
client.run(on_performer_updated_by_redis), name="Performer updated by redis"
112+
client.run(on_performer_updated_by_redis),
113+
name="Performer {} updated by redis".format(performer.name),
112114
)

0 commit comments

Comments
 (0)