Update app.py

app.py

@@ -5,6 +5,7 @@ import asyncio
 import aiohttp
 import zipfile
 import shutil
+import threading
 from typing import Dict, List, Set, Optional, Tuple, Any
 from urllib.parse import quote
 from datetime import datetime
@@ -494,16 +495,21 @@ app = FastAPI(
 
 @app.on_event("startup")
 async def startup_event():
-    print(f"Flow Server {FLOW_ID} started on port {FLOW_PORT}.")
+    print(f"[{FLOW_ID}] Flow Server started on port {FLOW_PORT}.")
+    print(f"[{FLOW_ID}] 🚀 Auto-starting background processing...")
+    
+    # Create a background task to run the processing loop
+    thread = threading.Thread(target=lambda: asyncio.run(process_audio_files_background()), daemon=True)
+    thread.start()
+    print(f"[{FLOW_ID}] ✅ Background processing thread started")
 
 @app.post("/process")
 async def process_audio_files(background_tasks: BackgroundTasks):
     """
-    Main processing endpoint that orchestrates transcription of audio files.
-    Fetches audio from HF dataset, sends to Whisper servers, and uploads results.
-    Uses reference file mapping for output filename renaming.
+    Manually trigger processing endpoint (in addition to auto-start on startup).
+    Orchestrates transcription of audio files with reference file mapping.
     """
-    print(f"[{FLOW_ID}] /process endpoint called, starting background task...")
+    print(f"[{FLOW_ID}] /process endpoint called, starting additional background task...")
     background_tasks.add_task(process_audio_files_background)
     return {
         "status": "processing_started",
@@ -511,8 +517,6 @@ async def process_audio_files(background_tasks: BackgroundTasks):
         "message": "Background processing task started. Check /status for progress."
     }
 
-# No wrapper needed - add_task can handle coroutine functions directly in newer FastAPI
-
 async def process_audio_files_background():
     """Background task that processes audio files with reference mapping."""
     progress_data = load_progress()