created a global worker manager

app/core/worker_manager.py

@@ -197,12 +197,14 @@ class WorkerManager:
 
 # ==================== FASTAPI INTEGRATION ====================
 
-# Global manager instance
+# Global manager instance (for app/main.py import)
+worker_manager = WorkerManager()
+
 _worker_manager: Optional[WorkerManager] = None
 
 
 async def get_worker_manager() -> WorkerManager:
-    """Get or create worker manager singleton"""
+    """Get or create worker manager singleton (async factory)"""
     global _worker_manager
     if _worker_manager is None:
         _worker_manager = WorkerManager()
@@ -234,7 +236,6 @@ async def trigger_kpi_computation(org_id: str, source_id: str):
         logger.error(f"Trigger failed: {e}", exc_info=True)
         return {"status": "error", "message": str(e)}
 
-
 # ==================== BACKGROUND REFRESH (Optional) ====================
 
 async def continuous_kpi_refresh(manager: WorkerManager):