Update app.py

app.py

@@ -549,7 +549,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                 print(f"[{video_id}] Exception deleting voice: {del_err}")
             
         # 5. Merge synthesized audio back with the original video (or run Lip-Sync if selected)
-        lipsync_output_path = f"temp_{video_id}_lipsync.mp4"
+        # NOTE: lipsync_output_path is already defined above using /tmp absolute path — do NOT redefine here.
         
         if job.has_lip_sync:
             print(f"[{video_id}] Setting up Wav2Lip model checkpoint files...")
@@ -568,12 +568,29 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             
             # Execute in the Wav2Lip directory to resolve relative imports
             result = subprocess.run(cmd_lipsync, cwd="Wav2Lip", capture_output=True, text=True)
+            # Always log stdout/stderr for debugging
+            if result.stdout:
+                print(f"[{video_id}] Wav2Lip stdout: {result.stdout[-2000:]}")
+            if result.stderr:
+                print(f"[{video_id}] Wav2Lip stderr: {result.stderr[-2000:]}")
             if result.returncode != 0:
-                print(f"Wav2Lip stdout: {result.stdout}")
-                print(f"Wav2Lip stderr: {result.stderr}")
-                raise Exception(f"Wav2Lip inference failed with exit code {result.returncode}: {result.stderr}")
+                raise Exception(f"Wav2Lip inference failed with exit code {result.returncode}: {result.stderr[-500:]}")
+            
+            # Verify Wav2Lip actually wrote the output file (it sometimes exits 0 without writing)
+            if not os.path.exists(lipsync_output_path) or os.path.getsize(lipsync_output_path) == 0:
+                # Search in Wav2Lip directory in case --outfile was treated as relative
+                wav2lip_relative_output = os.path.join("Wav2Lip", f"temp_{video_id}_lipsync.mp4")
+                results_default = os.path.join("Wav2Lip", "results", "result_voice.mp4")
+                if os.path.exists(wav2lip_relative_output) and os.path.getsize(wav2lip_relative_output) > 0:
+                    print(f"[{video_id}] WARNING: Wav2Lip wrote to relative path. Moving to expected location.")
+                    shutil.move(wav2lip_relative_output, lipsync_output_path)
+                elif os.path.exists(results_default) and os.path.getsize(results_default) > 0:
+                    print(f"[{video_id}] WARNING: Wav2Lip wrote to default results path. Copying to expected location.")
+                    shutil.copy2(results_default, lipsync_output_path)
+                else:
+                    raise Exception(f"Wav2Lip completed (exit 0) but output file not found at: {lipsync_output_path}")
                 
-            print(f"[{video_id}] Wav2Lip alignment completed successfully.")
+            print(f"[{video_id}] Wav2Lip alignment completed. Output size: {os.path.getsize(lipsync_output_path)} bytes")
             video_src_for_subtitles = lipsync_output_path
         else:
             video_src_for_subtitles = input_video_path