Stream tqdm progress lines by reading chunks and splitting on \r

app.py

@@ -130,13 +130,28 @@ def generate_video(image, prompt, resolution, steps, guidance_scale, frames, see
 
     log_lines = []
     proc = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.STDOUT,
-                            text=True, bufsize=1, env=env)
-
-    for line in proc.stdout:
-        stripped = line.rstrip()
-        log_lines.append(stripped)
-        print(stripped)
-        yield None, "\n".join(log_lines[-30:])
+                            text=True, bufsize=0, env=env)
+
+    buf = ""
+    while True:
+        chunk = proc.stdout.read(256)
+        if not chunk:
+            break
+        buf += chunk
+        # Split on \r or \n — tqdm uses \r to overwrite progress lines
+        parts = buf.replace("\r", "\n").split("\n")
+        buf = parts[-1]
+        for part in parts[:-1]:
+            stripped = part.strip()
+            if not stripped:
+                continue
+            # Overwrite last line if it looks like a progress bar update
+            if log_lines and ("%" in stripped or "it/s" in stripped or "step" in stripped.lower()):
+                log_lines[-1] = stripped
+            else:
+                log_lines.append(stripped)
+            print(stripped)
+            yield None, "\n".join(log_lines[-30:])
 
     proc.wait()
     log = "\n".join(log_lines)