fix: stream subprocess output in real-time

app.py

@@ -38,10 +38,10 @@ def _clone_repo(workdir: Path) -> Path:
     return repo_dir
 
 
-def _run_finish_review(repo_dir: Path, task_id: int) -> str:
-    result = subprocess.run(
+def _run_finish_review(repo_dir: Path, task_id: int) -> None:
+    proc = subprocess.Popen(
         [
-            sys.executable, str(repo_dir / "scripts" / "finish_review.py"),
+            sys.executable, "-u", str(repo_dir / "scripts" / "finish_review.py"),
             "--task-id", str(task_id),
             "--dataset", DATASET,
             "--experiment", f"cvat_review_{task_id}",
@@ -49,11 +49,16 @@ def _run_finish_review(repo_dir: Path, task_id: int) -> str:
             "--cvat-url", CVAT_URL,
             "--cvat-token", CVAT_TOKEN,
         ],
-        capture_output=True,
+        stdout=subprocess.PIPE,
+        stderr=subprocess.STDOUT,
         text=True,
         cwd=str(repo_dir),
     )
-    return result.stdout + result.stderr
+    for line in proc.stdout:
+        print(line, end="", flush=True)
+    proc.wait()
+    if proc.returncode != 0:
+        raise RuntimeError(f"finish_review exited with code {proc.returncode}")
 
 
 @app.post("/webhook")
@@ -82,14 +87,13 @@ async def cvat_webhook(request: Request):
         try:
             with tempfile.TemporaryDirectory() as workdir:
                 repo_dir = _clone_repo(Path(workdir))
-                print(f"Running finish_review for task {tid}...")
-                output = _run_finish_review(repo_dir, tid)
-                print(output)
-                print(f"finish_review completed for task {tid}")
+                print(f"Running finish_review for task {tid}...", flush=True)
+                _run_finish_review(repo_dir, tid)
+                print(f"finish_review completed for task {tid}", flush=True)
         except subprocess.TimeoutExpired:
-            print(f"finish_review timed out for task {tid}")
+            print(f"finish_review timed out for task {tid}", flush=True)
         except Exception as exc:
-            print(f"finish_review failed for task {tid}: {exc}")
+            print(f"finish_review failed for task {tid}: {exc}", flush=True)
 
     threading.Thread(target=_run_in_background, args=(task_id,), daemon=True).start()