changed worker manage import to get worker manager

app/main.py

@@ -21,7 +21,10 @@ from contextlib import asynccontextmanager
 
 # ─── Internal Imports ─────────────────────────────────────────────────────────
 from app.core.event_hub import event_hub
-from app.core.worker_manager import worker_manager
+# NOTE: worker_manager is now created via async factory `get_worker_manager()`
+# Old import kept as comment for reference:
+# from app.core.worker_manager import worker_manager
+from app.core.worker_manager import get_worker_manager,worker_manager
 from app.deps import rate_limit_org, verify_api_key, check_all_services
 from app.tasks.analytics_worker import trigger_kpi_computation
 from app.service.vector_service import cleanup_expired_vectors
@@ -106,6 +109,8 @@ async def lifespan(app: FastAPI):
     if os.getenv("DISABLE_WORKER_MANAGER") != "1":
         logger.info("🚀 starting worker manager...")
         try:
+            # Use the async factory to get the singleton manager instance
+            worker_manager = await get_worker_manager()
             asyncio.create_task(worker_manager.start_listener(), name="worker-manager")
         except Exception as e:
             logger.error(f"❌ Failed to start worker manager: {e}")