Update app.py

app.py

@@ -7,10 +7,36 @@ import uuid
 import shutil
 from tqdm import tqdm
 import threading
+import psutil, os
+
+def print_open_files(tag=""):
+    pid = os.getpid()
+    p = psutil.Process(pid)
+    print(f"[DEBUG] {tag} Open file descriptors:", p.num_fds())
+
+def print_process_count(tag=""):
+    proc_count = len(psutil.pids())
+    print(f"[DEBUG] {tag} Process count:", proc_count)
 
 def print_thread_count(tag=""):
     print(f"[DEBUG] {tag} Thread count:", len(threading.enumerate()))
 
+def print_ffmpeg_processes(tag=""):
+    count = 0
+    for p in psutil.process_iter(['name', 'cmdline']):
+        if 'ffmpeg' in (p.info['name'] or '') or \
+           any('ffmpeg' in (arg or '') for arg in (p.info['cmdline'] or [])):
+            count += 1
+    print(f"[DEBUG] {tag} FFmpeg running:", count)
+
+def debug_resources(tag=""):
+    print("========== RESOURCE DEBUG", tag, "==========")
+    print_thread_count()
+    print_process_count()
+    print_ffmpeg_processes()
+    print_open_files()
+    print("============================================")
+
 
 from huggingface_hub import snapshot_download, list_repo_files, hf_hub_download
 import importlib, site
@@ -295,7 +321,7 @@ def run_pipeline(prompt_text, steps, image_paths, audio_file_path, max_duration
         tea_cache_l1_thresh = 0.0,
         progress_bar_cmd=progress
     )
-    print_thread_count("after generation")
+    debug_resources("after generation")
 
     # Return resulting video path
     video_path = os.path.join(output_dir, f"{filename}.mp4")