refactored main.py for proper logign

app/main.py

@@ -3,12 +3,19 @@
 MutSyncHub Analytics Engine
 Enterprise-grade AI analytics platform with zero-cost inference
 """
+import logging
 
+# Configure logging to see all info messages
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s | %(name)s | %(levelname)s | %(message)s",
+    datefmt="%Y-%m-%d %H:%M:%S"
+)
 # ─── Standard Library ─────────────────────────────────────────────────────────
 import os
 import time
 import uuid
-import logging
+import subprocess
 
 # ─── Third-Party ──────────────────────────────────────────────────────────────
 from fastapi import FastAPI, Depends, HTTPException, Request
@@ -70,6 +77,10 @@ async def lifespan(app: FastAPI):
     except Exception as e:
         logger.error(f"🔴 Startup health check failed: {e}")
     
+    # Start scheduler in background
+    scheduler_process = subprocess.Popen(["python", "/app/scheduler_loop.py"])
+    logger.info(f"✅ Scheduler started (PID: {scheduler_process.pid})")
+    
     logger.info("✅ Startup sequence complete")
     yield
     
@@ -78,6 +89,10 @@ async def lifespan(app: FastAPI):
     logger.info("🛑 ANALYTICS ENGINE - SHUTDOWN SEQUENCE")
     logger.info("=" * 60)
     
+    # Close scheduler
+    scheduler_process.terminate()
+    logger.info("   → Stopped scheduler")
+    
     # Close all database connections
     from app.deps import _org_db_connections, _vector_db_conn
     
@@ -94,7 +109,7 @@ async def lifespan(app: FastAPI):
             _vector_db_conn.close()
             logger.info("   → Closed Vector DB")
         except:
-            pass
+        pass
     
     logger.info("✅ Shutdown complete")
 

scheduler_loop.py

@@ -1,7 +1,16 @@
 import json, time, os, requests
+import logging
 from datetime import datetime, timedelta  
 from pathlib import Path
 
+# Configure logging
+logging.basicConfig(
+    level=logging.INFO,
+    format="%(asctime)s | scheduler | %(levelname)s | %(message)s",
+    datefmt="%Y-%m-%d %H:%M:%S"
+)
+logger = logging.getLogger(__name__)
+
 SCHEDULE_FILE = "/data/.schedules.json"
 RUN_URL = "http://localhost:8000/analytics/run"   # inside container
 
@@ -19,7 +28,7 @@ def tick():
                 r = requests.post(RUN_URL,
                                   json={"analytic": analytic},
                                   headers={"X-Data-Path": f"/data/{s['orgId']}/sales.parquet"})
-                print(f"[scheduler] ran {analytic} for {s['orgId']} -> {r.status_code}")
+                logger.info(f"ran {analytic} for {s['orgId']} -> status={r.status_code}")
             # bump nextRun
             s["nextRun"] = (_next_run(s["frequency"])).isoformat()
 
@@ -34,9 +43,10 @@ def _next_run(frequency: str) -> datetime:
     return now
 
 if __name__ == "__main__":
+    logger.info("🔄 Scheduler loop started (60s interval)")
     while True:
         try:
             tick()
         except Exception as e:
-            print("[scheduler] error:", e)
+            logger.error(f"error: {e}")
         time.sleep(60)   # 1-minute granularity