Update app.py

app.py

@@ -12,18 +12,35 @@ import psutil
 
 PROC = psutil.Process(os.getpid())
 
-def debug_children_detail(limit=10):
+def debug_resources(tag=""):
+    # Threads in this process
+    thread_count = PROC.num_threads()
+
+    # Children processes spawned by this process (recursive = include grandchildren)
     children = PROC.children(recursive=True)
-    print(f"[DEBUG] Total children: {len(children)}")
-    for child in children[:limit]:
+    child_count = len(children)
+
+    # Group children by name to see what’s being spawned (ffmpeg, python, etc.)
+    name_counts = {}
+    for c in children:
         try:
-            print(
-                f"  PID={child.pid} status={child.status()} "
-                f"name={child.name()} cmdline={child.cmdline()[:5]}"
-            )
+            name = c.name()
         except psutil.Error:
-            pass
-
+            name = "unknown"
+        name_counts[name] = name_counts.get(name, 0) + 1
+
+    # File descriptors (Linux/macOS; on Windows use len(PROC.open_files()) instead)
+    try:
+        fd_count = PROC.num_fds()
+    except AttributeError:
+        fd_count = len(PROC.open_files())
+
+    print("========== RESOURCE DEBUG", tag, "==========")
+    print("[DEBUG]", "Threads in this process:", thread_count)
+    print("[DEBUG]", "Child processes (recursive):", child_count)
+    print("[DEBUG]", "Child processes by name:", name_counts)
+    print("[DEBUG]", "Open file descriptors:", fd_count)
+    print("============================================")
 
 from huggingface_hub import snapshot_download, list_repo_files, hf_hub_download
 import importlib, site
@@ -167,17 +184,9 @@ def update_required_time(steps, max_duration):
 
     return get_required_time_string(steps, max_duration)
 
-num_scene_generation = 0
 
 def generate_scene(prompt_text, steps, image_paths, audio_file_path, max_duration = 3, session_id = None, progress=gr.Progress(),):
 
-    global num_scene_generation
-    if num_scene_generation % 30 == 0:
-        debug_children_detail()
-    num_scene_generation = num_scene_generation + 1
-
-    
-
     prompt_text_check = (prompt_text or "").strip()
     if not prompt_text_check:
         raise gr.Error("Please enter a prompt.")
@@ -316,7 +325,8 @@ def run_pipeline(prompt_text, steps, image_paths, audio_file_path, max_duration
         tea_cache_l1_thresh = 0.0,
         progress_bar_cmd=progress
     )
-    
+    debug_resources("after generation")
+
     # Return resulting video path
     video_path = os.path.join(output_dir, f"{filename}.mp4")
     if os.path.exists(video_path):