Upload api.py

api.py

@@ -112,16 +112,16 @@ def get_job_status(job_id: str):
     
     job = jobs[job_id]
     
-    response = {
-        "status": job["status"]
-    }
-    
-    # Si está completado, incluir resultados
-    if job["status"] == JobStatus.DONE:
+    # Normalizar el estado a string
+    status_value = job["status"].value if isinstance(job["status"], JobStatus) else str(job["status"])
+    response = {"status": status_value}
+
+    # Incluir resultados si existen (evita condiciones de carrera)
+    if job.get("results") is not None:
         response["results"] = job["results"]
-    
-    # Si falló, incluir error
-    elif job["status"] == JobStatus.FAILED:
+
+    # Incluir error si existe
+    if job.get("error"):
         response["error"] = job["error"]
     
     return response
@@ -182,14 +182,14 @@ def process_video_job(job_id: str):
             for char in characters:
                 print(f"[{job_id}]   - {char['name']}: {char['num_faces']} caras")
             
-            # Marcar como completado
-            job["status"] = JobStatus.DONE
+            # Guardar resultados primero y luego marcar como completado (evita carreras)
             job["results"] = {
                 "characters": characters,
                 "num_characters": len(characters),
                 "analysis_path": analysis_path,
                 "base_dir": str(base)
             }
+            job["status"] = JobStatus.DONE
             
             print(f"[{job_id}] DEBUG - job['results'] guardado: {job['results']}")
             
@@ -204,7 +204,7 @@ def process_video_job(job_id: str):
             for sub in ("sources", "faces", "voices", "backgrounds"):
                 (base / sub).mkdir(parents=True, exist_ok=True)
             
-            job["status"] = JobStatus.DONE
+            # Guardar resultados de fallback y luego marcar como completado
             job["results"] = {
                 "characters": [],
                 "num_characters": 0,
@@ -216,6 +216,7 @@ def process_video_job(job_id: str):
                 },
                 "warning": f"Detección falló, usando modo fallback: {str(e_detect)}"
             }
+            job["status"] = JobStatus.DONE
         
         print(f"[{job_id}] ✓ Job completado exitosamente")