From 95b6560ffd75b91f1b844f2ac5983b828401976a Mon Sep 17 00:00:00 2001 From: zhenyus Date: Sun, 3 Aug 2025 02:48:55 +0800 Subject: [PATCH] refactor: improve clarity of subscriber startup process in message_queue.py Updated comment to specify that the subscriber starts in the background, enhancing code readability and understanding of the asynchronous behavior. Signed-off-by: zhenyus --- apps/devops/app/providers/message_queue.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/devops/app/providers/message_queue.py b/apps/devops/app/providers/message_queue.py index b272db4..51cb071 100644 --- a/apps/devops/app/providers/message_queue.py +++ b/apps/devops/app/providers/message_queue.py @@ -19,9 +19,9 @@ def register(app): ) print("Registered deployment heartbeat processor") - # Start the subscriber + # Start the subscriber in the background loop = asyncio.get_running_loop() - await loop.create_task( + loop.create_task( app.deployment_heartbeat_subscriber.subscribe(max_retries=5, event_loop=loop) ) print("Started deployment heartbeat subscriber")