Fix 502 timeout: Upload returns immediately, processing starts on first status check

highlights_api.py

@@ -155,23 +155,27 @@ async def upload_video(
             }
         }
         
-        # Start processing in background
-        background_tasks.add_task(
-            process_video_highlights,
-            job_id,
-            temp_video_path,
-            interval,
-            min_score,
-            max_highlights,
-            whisper_model,
-            timeout,
-            enable_visual
-        )
+        # Store job parameters for immediate return
+        active_jobs[job_id] = {
+            "status": "queued",
+            "progress": 0,
+            "message": "Video uploaded. Processing will start shortly.",
+            "params": {
+                "video_path": temp_video_path,
+                "interval": interval,
+                "min_score": min_score,
+                "max_highlights": max_highlights,
+                "whisper_model": whisper_model,
+                "timeout": timeout,
+                "enable_visual": enable_visual
+            }
+        }
         
+        # Return immediately - processing will be triggered by first status check
         return AnalysisResponse(
             job_id=job_id,
-            status="processing",
-            message="Video uploaded successfully. Processing started."
+            status="queued",
+            message="Video uploaded successfully. Check status to begin processing."
         )
         
     except Exception as e:
@@ -186,6 +190,29 @@ async def get_job_status(job_id: str):
     # Check active jobs
     if job_id in active_jobs:
         job = active_jobs[job_id]
+        
+        # If job is queued, start processing
+        if job["status"] == "queued":
+            # Start processing in background
+            params = job["params"]
+            asyncio.create_task(
+                process_video_highlights_async(
+                    job_id,
+                    params["video_path"],
+                    params["interval"],
+                    params["min_score"],
+                    params["max_highlights"],
+                    params["whisper_model"],
+                    params["timeout"],
+                    params["enable_visual"]
+                )
+            )
+            
+            # Update status to processing
+            active_jobs[job_id]["status"] = "processing"
+            active_jobs[job_id]["progress"] = 5
+            active_jobs[job_id]["message"] = "Processing started..."
+        
         return JobStatus(
             job_id=job_id,
             status=job["status"],
@@ -222,7 +249,7 @@ async def download_file(filename: str):
         filename=filename
     )
 
-async def process_video_highlights(
+async def process_video_highlights_async(
     job_id: str,
     video_path: str,
     interval: float,
@@ -273,6 +300,9 @@ async def process_video_highlights(
                 # Analyze segment
                 analysis = analyzer.analyze_segment(video_path, segment, temp_frame_path)
                 analyzed_segments.append(analysis)
+            
+            # Yield control to allow other requests
+            await asyncio.sleep(0)
         
         # Cleanup temp frame
         try: