feat(ui): streaming progress updates per pipeline stage in Gradio

gradio_app/app.py

@@ -625,32 +625,48 @@ async def _run_pipeline(github_url: str):
 
 
 def run_analysis(github_url: str):
-    """
-    Returns a tuple of 9 Gradio component updates:
-      0  overview_html
-      1  bugs_html
-      2  review_html
-      3  tests_code
-      4  report_md
-      5  status_text
-      6  score_html
-      7  stats_html
-      8  refactor_html
-    """
+    empty = _empty_state("Run analysis to see results.")
+    empty_defaults = (empty, empty, empty, "", "# No report yet.", "", empty, "", "")
+
     if not github_url.strip():
-        empty = _empty_state("Enter a GitHub URL above to get started.")
-        return empty, empty, empty, "", "# No report yet.", "⬡  Waiting for input.", "", "", ""
+        yield (_empty_state("Enter a GitHub URL above to get started."),) + empty_defaults[1:]
+        return
 
     url = github_url.strip()
     if not url.startswith("https://github.com/"):
         err = _empty_state("❌  URL must start with https://github.com/")
-        return err, err, err, "", "# Invalid URL", "❌  Invalid GitHub URL.", "", "", ""
+        yield (err, err, err, "", "# Invalid URL", "❌  Invalid GitHub URL.", "", "", err)
+        return
 
+    local_path = None
     try:
-        report = asyncio.run(_run_pipeline(url))
+        # Step 1 — clone
+        yield empty_defaults[:5] + ("⏳  [1/5]  Cloning repository...",) + empty_defaults[6:]
+        local_path = clone_repository(url)
+
+        # Step 2 — repo analysis
+        yield empty_defaults[:5] + ("⏳  [2/5]  Analysing repository structure...",) + empty_defaults[6:]
+        metadata = asyncio.run(repo_analysis_agent.run(url, local_path))
+
+        # Step 3 — parallel agents
+        yield empty_defaults[:5] + ("⏳  [3/5]  Running bug detection, test generation and code review in parallel...",) + empty_defaults[6:]
+        issues, tests, review = asyncio.run(asyncio.gather(
+            bug_detection_agent.run(local_path),
+            test_generation_agent.run(local_path),
+            code_review_agent.run(local_path, metadata),
+        ))
+
+        # Step 4 — report
+        yield empty_defaults[:5] + ("⏳  [4/5]  Generating engineering report...",) + empty_defaults[6:]
+        report = asyncio.run(report_generator_agent.run(metadata, issues, tests, review))
+
     except Exception as e:
-        err = _empty_state(f"❌  Pipeline error: {e}")
-        return err, err, err, "", f"# Error\n\n```\n{e}\n```", f"❌  {e}", "", "", ""
+        err = _empty_state(f"❌  {e}")
+        yield (err, err, err, "", f"# Error\n\n```\n{e}\n```", f"❌  {e}", "", "", err)
+        return
+    finally:
+        if local_path:
+            delete_repository(local_path)
 
     m  = report.repository
     i  = report.issues
@@ -796,7 +812,6 @@ def run_analysis(github_url: str):
 </div>
 """
 
-    # ── Refactor tab ──
     refactor_html = f"""
 <div class="section-header">Refactor Suggestions</div>
 {_list_items(rv.refactor_suggestions)}
@@ -804,7 +819,7 @@ def run_analysis(github_url: str):
 
     status_text = f"✓  Analysis complete — {m.name} · {m.language} · score {score}/10"
 
-    return (
+    yield (
         overview_html,
         bugs_html,
         review_html,
@@ -924,7 +939,7 @@ with gr.Blocks(css=CSS, title="AI Code Review Agent", theme=gr.themes.Base()) as
             stats_state,
             refactor_out,
         ],
-        show_progress="full",
+        show_progress="hidden",
     )
 
 if __name__ == "__main__":