Log a warning for pending asyncio tasks with coroutine details

This commit is contained in:
dst03106
2025-05-13 17:37:09 +09:00
parent d86d1ef3dc
commit e2af22d2a0

View File

@ -88,9 +88,11 @@ def run(inargs=None, args=None):
get_logger().debug("Waiting for event queue to complete")
tasks = [task for task in asyncio.all_tasks() if task is not asyncio.current_task()]
if tasks:
done, pending = await asyncio.wait(tasks, timeout=30)
_, pending = await asyncio.wait(tasks, timeout=30)
if pending:
get_logger().warning(f"{len(pending)} callback tasks did not complete within timeout")
get_logger().warning(
f"{len(pending)} callback tasks({[task.get_coro() for task in pending]}) did not complete within timeout"
)
return result