Update app.py

app.py

@@ -261,6 +261,14 @@ def get_ffmpeg_style(caption_style: str, custom_font: str = None, custom_size: i
     style_str = ",".join([f"{k}={v}" for k, v in style.items()])
     return style_str
 
+def run_ffmpeg_command(cmd, task_name="FFmpeg"):
+    print(f"Running {task_name} command: {' '.join(cmd)}")
+    res = subprocess.run(cmd, capture_output=True, text=True)
+    if res.returncode != 0:
+        error_logs = res.stderr.strip().splitlines()
+        last_logs = "\n".join(error_logs[-6:]) if error_logs else "No error logs outputted."
+        raise Exception(f"{task_name} failed with exit code {res.returncode}. FFmpeg error logs:\n{last_logs}")
+
 @app.get("/")
 def read_root():
     gemini_key, eleven_key, is_mock = get_api_keys()
@@ -390,7 +398,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             "-c:a", "aac", "-ar", "16000", "-ac", "1",
             input_video_path
         ])
-        subprocess.run(cmd_standardize, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+        run_ffmpeg_command(cmd_standardize, "Video Standardization")
         
         # 2. Extract audio from video using FFmpeg
         print(f"[{video_id}] Extracting audio using FFmpeg...")
@@ -399,7 +407,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             "-vn", "-acodec", "libmp3lame", "-q:a", "2",
             extracted_audio_path
         ]
-        subprocess.run(cmd_extract, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+        run_ffmpeg_command(cmd_extract, "Audio Extraction")
         
         # 3. Request Transcription & Translation from Gemini 2.5 Flash
         print(f"[{video_id}] Calling Gemini 2.5 Flash for transcription/translation to '{job.target_lang}'...")
@@ -596,7 +604,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                     "-c:v", "libx264", "-pix_fmt", "yuv420p", "-c:a", "aac", "-shortest",
                     output_video_path
                 ]
-            subprocess.run(cmd_merge, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+            run_ffmpeg_command(cmd_merge, "Subtitle Burning & Video Merge")
         else:
             if job.has_lip_sync:
                 print(f"[{video_id}] Copying lip-synced video to final output path...")
@@ -608,7 +616,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                     "-map", "0:v", "-map", "1:a", "-c:v", "copy", "-c:a", "aac", "-shortest",
                     output_video_path
                 ]
-                subprocess.run(cmd_merge, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+                run_ffmpeg_command(cmd_merge, "Audio-Video Merge")
                 
         # Normalize Supabase base URL (remove trailing slash and rest/v1 path if present)
         base_url = supabase_url.rstrip("/")