icecheng/freeleaps-service-hub
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request 'fix: use environment variable for RabbitMQ output queue name' (#23) from Nicolas_devops_reconciler into dev

Browse Source 
Reviewed-on: freeleaps/freeleaps-service-hub#23
This commit is contained in:
freeleaps-admin 2025-08-08 04:06:43 +00:00
commit fc4c8e7b14
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
apps/devops/app/providers/message_queue.py
View File

@ -1,4 +1,5 @@
import asyncio import asyncio
import os
from app.backend.infra.rabbitmq.async_subscriber import AsyncMQSubscriber from app.backend.infra.rabbitmq.async_subscriber import AsyncMQSubscriber
from app.backend.services.deployment_status_update_service import DeploymentStatusUpdateService from app.backend.services.deployment_status_update_service import DeploymentStatusUpdateService
@ -15,7 +16,9 @@ def register(app):
try: try:
# Initialize services during startup to avoid blocking app initialization # Initialize services during startup to avoid blocking app initialization
print("🔧 Initializing services...") print("🔧 Initializing services...")
app.deployment_heartbeat_subscriber = AsyncMQSubscriber("reconciler.output") output_queue_name = os.getenv("RABBITMQ_OUTPUT_QUEUE_NAME", "freeleaps.devops.reconciler.output")
print(f"Using output queue: {output_queue_name}")
app.deployment_heartbeat_subscriber = AsyncMQSubscriber(output_queue_name)
app.deployment_status_service = DeploymentStatusUpdateService() app.deployment_status_service = DeploymentStatusUpdateService()
print("✅ Services initialized") print("✅ Services initialized")