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")