refactor: job handling to use update_job for completion and failure states

Author: adithayyil

backend/database/job_store_connector.py

@@ -86,13 +86,12 @@ def job_exists(self, job_id: str) -> bool:
     def set_job_completed(self, job_id: str, result_data: Dict[str, Any]) -> bool:
         """Mark job as completed with result data."""
         result_data["status"] = "completed"
-        return self.create_job(job_id, result_data)
+        return self.update_job(job_id, result_data)
 
     def set_job_failed(self, job_id: str, error: str) -> bool:
         """Mark job as failed with error message."""
         error_data = {
-            "job_id": job_id,
             "status": "failed",
             "error": error
         }
-        return self.create_job(job_id, error_data)
+        return self.update_job(job_id, error_data)

backend/main.py

@@ -163,6 +163,15 @@ async def upload(self, file: UploadFile = None):
         # Log upload details
         logger.info(f"[Upload] {job_id}: {file.filename} ({file_size} bytes, {file.content_type})")
 
+        # Create initial job entry in shared storage
+        self.job_store.create_job(job_id, {
+            "job_id": job_id,
+            "filename": file.filename,
+            "status": "processing",
+            "size_bytes": file_size,
+            "content_type": file.content_type
+        })
+
         # Spawn background processing (non-blocking - returns immediately)
         self.process_video.spawn(contents, file.filename, job_id)