From 9283e52e487d0f842fb81bb5065fbfb85cf6b1fe Mon Sep 17 00:00:00 2001 From: zhenyus Date: Sun, 3 Aug 2025 02:38:33 +0800 Subject: [PATCH] feat: enhance message consumer startup and shutdown logging in message_queue.py Added print statements to log the status of message consumers during startup and shutdown processes, improving traceability and debugging capabilities. Signed-off-by: zhenyus --- apps/devops/app/providers/message_queue.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/apps/devops/app/providers/message_queue.py b/apps/devops/app/providers/message_queue.py index 03ecb00..b272db4 100644 --- a/apps/devops/app/providers/message_queue.py +++ b/apps/devops/app/providers/message_queue.py @@ -10,21 +10,27 @@ def register(app): @app.on_event("startup") async def start_message_consumers(): + print("Starting message consumers") # Register the heartbeat processor await app.deployment_heartbeat_subscriber.register_consumer( registry_key="deployment_heartbeat_processor", callback_method=app.deployment_status_service.process_heartbeat_message, args={} ) + print("Registered deployment heartbeat processor") # Start the subscriber loop = asyncio.get_running_loop() await loop.create_task( app.deployment_heartbeat_subscriber.subscribe(max_retries=5, event_loop=loop) ) + print("Started deployment heartbeat subscriber") @app.on_event("shutdown") async def stop_message_consumers(): # Clear consumers and close connection + print("Stopping message consumers") await app.deployment_heartbeat_subscriber.clear_all_consumers() - await app.deployment_heartbeat_subscriber.close() \ No newline at end of file + print("Cleared all consumers") + await app.deployment_heartbeat_subscriber.close() + print("Closed deployment heartbeat subscriber") \ No newline at end of file