Improve compare progress for large BGP sheets.

Show pending check items instead of a fake 100% pass, publish sheet results as each finishes, and use keyset chunk loads with rows-loaded progress.

Co-authored-by: Cursor <cursoragent@cursor.com>

netx_api/biz_state/compare_service.py

@@ -9,10 +9,11 @@ import threading
 import time
 import zipfile
 from datetime import datetime
-from typing import Any
+from typing import Any, Callable
 from uuid import uuid4
 
 from fastapi import HTTPException
+from sqlalchemy import and_, or_
 from sqlalchemy.orm import Session
 
 from ..models import (
@@ -429,6 +430,10 @@ def _sheet_meta_from_summary(summary: dict[str, Any], run: BizCompareRun, tpl: A
     sheets = list(summary.get("sheets") or [])
     if sheets:
         return sheets
+    # Running / empty: do NOT invent a fake first-metric sheet (was showing
+    # isis 100% with 0→0 while BGP was still loading).
+    if str(run.status or "") in ("running", "queued"):
+        return []
     return [
         {
             "metric_id": run.metric_id,
@@ -438,6 +443,7 @@ def _sheet_meta_from_summary(summary: dict[str, Any], run: BizCompareRun, tpl: A
             "iface_fields": list((tpl.iface_fields if tpl else None) or []),
             "compare_fields": list((tpl.compare_fields if tpl else None) or []),
             "mode": "fields",
+            "status": "done",
             "summary": {
                 k: summary.get(k, 0)
                 for k in ("added", "removed", "changed", "unchanged", "before_count", "after_count")
@@ -447,6 +453,33 @@ def _sheet_meta_from_summary(summary: dict[str, Any], run: BizCompareRun, tpl: A
     ]
 
 
+def _pending_sheet_meta(sheet: dict[str, Any]) -> dict[str, Any]:
+    """Placeholder meta so the UI lists all check items while a run is in flight."""
+    key_fields = list(sheet.get("key_fields") or [])
+    compare_fields = list(sheet.get("compare_fields") or [])
+    return {
+        "sheet_id": sheet_key(sheet),
+        "title": sheet_title(sheet),
+        "metric_id": sheet.get("metric_id") or "",
+        "key_fields": key_fields,
+        "iface_fields": list(sheet.get("iface_fields") or []),
+        "compare_fields": compare_fields,
+        "display_fields": list(sheet.get("display_fields") or []),
+        "field_rules": list(sheet.get("field_rules") or []),
+        "ignore_port_changes": sheet.get("ignore_port_changes"),
+        "mode": "presence" if not compare_fields else "fields",
+        "status": "pending",
+        "summary": {
+            "added": 0,
+            "removed": 0,
+            "changed": 0,
+            "unchanged": 0,
+            "before_count": 0,
+            "after_count": 0,
+        },
+    }
+
+
 def _str_list(raw: Any) -> list[str]:
     return [str(x).strip() for x in (raw or []) if str(x).strip()]
 
@@ -1347,70 +1380,109 @@ def _port_map_dict(db: Session, mapping_id: str) -> dict[str, str]:
     return {str(r.before_if): str(r.after_if) for r in rows if r.before_if and r.after_if}
 
 
-def _load_metric_rows(db: Session, *, batch_id: str, metric_id: str) -> list[dict[str, Any]]:
-    """Load metric rows with streaming fetch to avoid holding the full ORM set."""
+def _load_metric_rows(
+    db: Session,
+    *,
+    batch_id: str,
+    metric_id: str,
+    on_chunk: Callable[[int], None] | None = None,
+) -> list[dict[str, Any]]:
+    """Load metric rows in keyset chunks (stable on million-row sheets).
+
+    Avoids ORM ``yield_per``/``unique()`` clash and OFFSET degradation on BGP-sized tables.
+    ``on_chunk(loaded_count)`` is called after each chunk for progress UI.
+    """
     if metric_id == "lldp_neighbor":
-        q = (
-            db.query(BizStateLldpNeighbor)
-            .filter(BizStateLldpNeighbor.batch_id == batch_id)
-            .execution_options(stream_results=True, yield_per=_LOAD_YIELD_PER)
-        )
         out: list[dict[str, Any]] = []
-        for n in q:
-            out.append(
-                {
-                    "local_if": n.local_if,
-                    "remote_sys": n.remote_sys,
-                    "remote_if": n.remote_if,
-                    "remote_ip": n.remote_ip,
-                    "protocol": n.protocol,
-                    "_netx": {
-                        "batch_id": batch_id,
-                        "batch_command_id": n.batch_command_id or "",
-                        "task_id": n.task_id or "",
-                        "ne_id": n.ne_id or "",
-                        "collected_at": n.collected_at.isoformat() + "Z"
-                        if n.collected_at
-                        else None,
-                        "row_id": n.id,
-                    },
-                }
-            )
-            db.expunge(n)
+        last_id = ""
+        while True:
+            q = db.query(BizStateLldpNeighbor).filter(BizStateLldpNeighbor.batch_id == batch_id)
+            if last_id:
+                q = q.filter(BizStateLldpNeighbor.id > last_id)
+            chunk = q.order_by(BizStateLldpNeighbor.id.asc()).limit(_LOAD_YIELD_PER).all()
+            if not chunk:
+                break
+            for n in chunk:
+                out.append(
+                    {
+                        "local_if": n.local_if,
+                        "remote_sys": n.remote_sys,
+                        "remote_if": n.remote_if,
+                        "remote_ip": n.remote_ip,
+                        "protocol": n.protocol,
+                        "_netx": {
+                            "batch_id": batch_id,
+                            "batch_command_id": n.batch_command_id or "",
+                            "task_id": n.task_id or "",
+                            "ne_id": n.ne_id or "",
+                            "collected_at": n.collected_at.isoformat() + "Z"
+                            if n.collected_at
+                            else None,
+                            "row_id": n.id,
+                        },
+                    }
+                )
+                db.expunge(n)
+            last_id = str(chunk[-1].id)
+            if on_chunk:
+                on_chunk(len(out))
+            if len(chunk) < _LOAD_YIELD_PER:
+                break
         return out
     # Generic tabular metrics (ISIS / interface / ARP / ND6 / BGP …)
     from ..models import BizStateMetricRow
 
-    q = (
-        db.query(BizStateMetricRow)
-        .filter(
+    out: list[dict[str, Any]] = []
+    last_seq = -1
+    last_id = ""
+    while True:
+        q = db.query(BizStateMetricRow).filter(
             BizStateMetricRow.batch_id == batch_id,
             BizStateMetricRow.metric_id == metric_id,
         )
-        .order_by(BizStateMetricRow.seq.asc(), BizStateMetricRow.id.asc())
-        .execution_options(stream_results=True, yield_per=_LOAD_YIELD_PER)
-    )
-    out = []
-    for r in q:
-        # Raw rows only — filtering belongs to the compare sheet template
-        # (``row_filters``), not metric-specific branches here.
-        # ``_netx`` is collector provenance (stripped before field compare).
-        out.append(
-            {
-                **dict(r.data_json or {}),
-                "_netx": {
-                    "batch_id": batch_id,
-                    "batch_command_id": r.batch_command_id or "",
-                    "task_id": r.task_id or "",
-                    "ne_id": r.ne_id or "",
-                    "collected_at": r.collected_at.isoformat() + "Z"
-                    if r.collected_at
-                    else None,
-                    "row_id": r.id,
-                },
-            }
+        if last_id:
+            q = q.filter(
+                or_(
+                    BizStateMetricRow.seq > last_seq,
+                    and_(
+                        BizStateMetricRow.seq == last_seq,
+                        BizStateMetricRow.id > last_id,
+                    ),
+                )
+            )
+        chunk = (
+            q.order_by(BizStateMetricRow.seq.asc(), BizStateMetricRow.id.asc())
+            .limit(_LOAD_YIELD_PER)
+            .all()
         )
-        db.expunge(r)
+        if not chunk:
+            break
+        for r in chunk:
+            # Raw rows only — filtering belongs to the compare sheet template
+            # (``row_filters``), not metric-specific branches here.
+            # ``_netx`` is collector provenance (stripped before field compare).
+            out.append(
+                {
+                    **dict(r.data_json or {}),
+                    "_netx": {
+                        "batch_id": batch_id,
+                        "batch_command_id": r.batch_command_id or "",
+                        "task_id": r.task_id or "",
+                        "ne_id": r.ne_id or "",
+                        "collected_at": r.collected_at.isoformat() + "Z"
+                        if r.collected_at
+                        else None,
+                        "row_id": r.id,
+                    },
+                }
+            )
+            db.expunge(r)
+        last_seq = int(chunk[-1].seq or 0)
+        last_id = str(chunk[-1].id)
+        if on_chunk:
+            on_chunk(len(out))
+        if len(chunk) < _LOAD_YIELD_PER:
+            break
     if out:
         return out
     # Known metric with zero rows is OK; unknown metric still errors
@@ -1609,6 +1681,7 @@ def _run_sheet(
     port_map: dict[str, str],
     iface_normalize_rules: list[dict[str, str]] | None = None,
     store_unchanged: str = "auto",
+    on_load_progress: Callable[[str, int], None] | None = None,
 ) -> dict[str, Any]:
     key_fields = list(sheet.get("key_fields") or [])
     iface_fields = list(sheet.get("iface_fields") or [])
@@ -1629,8 +1702,22 @@ def _run_sheet(
     ignore_ports = sheet.get("ignore_port_changes")
     if ignore_ports is not None:
         ignore_ports = bool(ignore_ports)
-    before_raw = _load_metric_rows(db, batch_id=before_batch_id, metric_id=sheet["metric_id"])
-    after_raw = _load_metric_rows(db, batch_id=after_batch_id, metric_id=sheet["metric_id"])
+    mid = sheet["metric_id"]
+
+    def _before_chunk(n: int) -> None:
+        if on_load_progress:
+            on_load_progress("before", n)
+
+    def _after_chunk(n: int) -> None:
+        if on_load_progress:
+            on_load_progress("after", n)
+
+    before_raw = _load_metric_rows(
+        db, batch_id=before_batch_id, metric_id=mid, on_chunk=_before_chunk
+    )
+    after_raw = _load_metric_rows(
+        db, batch_id=after_batch_id, metric_id=mid, on_chunk=_after_chunk
+    )
     before_rows = apply_row_filters(before_raw, row_filters)
     after_rows = apply_row_filters(after_raw, row_filters)
     policy = resolve_unchanged_policy(
@@ -1667,6 +1754,7 @@ def _run_sheet(
         "field_rules": field_rules,
         "ignore_port_changes": ignore_ports,
         "mode": mode,
+        "status": "done",
         "summary": summary,
         "diffs": result["diffs"],
         "mapping_stats": result["mapping_stats"],
@@ -1715,6 +1803,7 @@ def _create_running_run(
     sheets_cfg: list[dict[str, Any]],
 ) -> BizCompareRun:
     first_metric = str(sheets_cfg[0].get("metric_id") or "")
+    pending_sheets = [_pending_sheet_meta(s) for s in sheets_cfg]
     run = BizCompareRun(
         id=uuid4().hex,
         job_id=job.id,
@@ -1741,7 +1830,7 @@ def _create_running_run(
             "duplicate": 0,
             "before_count": 0,
             "after_count": 0,
-            "sheets": [],
+            "sheets": pending_sheets,
         },
         diffs_json=[],
         mapping_stats_json={},
@@ -1822,7 +1911,6 @@ def _execute_compare_into_run(db: Session, run_id: str) -> dict[str, Any]:
     store_mode = normalize_store_unchanged(getattr(j, "store_unchanged", None))
     pmap = _port_map_dict(db, run.mapping_id)
     norm_rules = template_iface_normalize(tpl)
-    sheet_metas: list[dict[str, Any]] = []
     unchanged_listed_total = 0
     unchanged_truncated_any = False
     unchanged_compact_any = False
@@ -1839,8 +1927,51 @@ def _execute_compare_into_run(db: Session, run_id: str) -> dict[str, Any]:
     field_counts: dict[str, int] = {}
     total = len(sheets_cfg)
 
+    # Prefer seeded pending sheets from create; rebuild if missing
+    sheet_metas: list[dict[str, Any]] = list((run.summary_json or {}).get("sheets") or [])
+    if len(sheet_metas) != total:
+        sheet_metas = [_pending_sheet_meta(s) for s in sheets_cfg]
+
+    def _publish_sheets() -> None:
+        prev = dict(run.summary_json or {})
+        prev["sheets"] = list(sheet_metas)
+        prev.update({k: agg[k] for k in agg})
+        run.summary_json = prev
+        db.commit()
+
     try:
         for idx, sheet in enumerate(sheets_cfg, start=1):
+            sid = sheet_key(sheet)
+            # Mark current sheet running in the sidebar list
+            for meta in sheet_metas:
+                if sheet_key(meta) == sid:
+                    meta["status"] = "running"
+                    break
+            _publish_sheets()
+
+            _load_pub = {"t": 0.0, "n": -1}
+
+            def _on_load(side: str, n: int, _idx: int = idx, _sheet: dict = sheet) -> None:
+                now = time.monotonic()
+                # Avoid committing every 5k on million-row BGP loads
+                if n - _load_pub["n"] < 25_000 and now - _load_pub["t"] < 2.0:
+                    return
+                _load_pub["t"] = now
+                _load_pub["n"] = n
+                _set_run_progress(
+                    db,
+                    run,
+                    phase="loading",
+                    sheet_index=_idx,
+                    sheet_total=total,
+                    sheet=_sheet,
+                    started_mono=started_mono,
+                    extra={
+                        "load_side": side,
+                        "rows_loaded": n,
+                    },
+                )
+
             _set_run_progress(
                 db,
                 run,
@@ -1858,6 +1989,7 @@ def _execute_compare_into_run(db: Session, run_id: str) -> dict[str, Any]:
                 port_map=pmap,
                 iface_normalize_rules=norm_rules,
                 store_unchanged=store_mode,
+                on_load_progress=_on_load,
             )
             s = one["summary"]
             listed = int(s.get("unchanged_listed") or 0)
@@ -1869,7 +2001,7 @@ def _execute_compare_into_run(db: Session, run_id: str) -> dict[str, Any]:
             _set_run_progress(
                 db,
                 run,
-                phase="persisting",
+                phase="comparing",
                 sheet_index=idx,
                 sheet_total=total,
                 sheet=sheet,
@@ -1930,21 +2062,29 @@ def _execute_compare_into_run(db: Session, run_id: str) -> dict[str, Any]:
             for k in agg:
                 agg[k] += int(s.get(k) or 0)
             mapping_by_metric[mid] = one["mapping_stats"]
-            sheet_metas.append(
-                {
-                    "sheet_id": one.get("sheet_id") or one["metric_id"],
-                    "title": one.get("title") or one.get("sheet_id") or one["metric_id"],
-                    "metric_id": one["metric_id"],
-                    "key_fields": one["key_fields"],
-                    "iface_fields": one["iface_fields"],
-                    "compare_fields": one["compare_fields"],
-                    "display_fields": one.get("display_fields") or [],
-                    "field_rules": one.get("field_rules") or [],
-                    "ignore_port_changes": one.get("ignore_port_changes"),
-                    "mode": one["mode"],
-                    "summary": one["summary"],
-                }
-            )
+            done_meta = {
+                "sheet_id": one.get("sheet_id") or one["metric_id"],
+                "title": one.get("title") or one.get("sheet_id") or one["metric_id"],
+                "metric_id": one["metric_id"],
+                "key_fields": one["key_fields"],
+                "iface_fields": one["iface_fields"],
+                "compare_fields": one["compare_fields"],
+                "display_fields": one.get("display_fields") or [],
+                "field_rules": one.get("field_rules") or [],
+                "ignore_port_changes": one.get("ignore_port_changes"),
+                "mode": one["mode"],
+                "status": "done",
+                "summary": one["summary"],
+            }
+            replaced = False
+            for i, meta in enumerate(sheet_metas):
+                if sheet_key(meta) == mid:
+                    sheet_metas[i] = done_meta
+                    replaced = True
+                    break
+            if not replaced:
+                sheet_metas.append(done_meta)
+            _publish_sheets()
             # Drop heavy diffs before next sheet
             one.clear()
             diffs.clear()
@@ -2167,12 +2307,15 @@ def _enrich_summary(summary: dict[str, Any], sheets: list[dict[str, Any]]) -> di
         st = sa + sr + sc + su
         sf = sr + sc
         sj = sf + su
+        status = str(sh.get("status") or "done")
+        pending = status in ("pending", "running", "queued")
         sheet_cards.append(
             {
                 "sheet_id": sheet_key(sh),
                 "title": sheet_title(sh),
                 "metric_id": sh.get("metric_id") or "",
                 "mode": sh.get("mode") or ("presence" if not sh.get("compare_fields") else "fields"),
+                "status": status,
                 "added": sa,
                 "removed": sr,
                 "changed": sc,
@@ -2182,7 +2325,10 @@ def _enrich_summary(summary: dict[str, Any], sheets: list[dict[str, Any]]) -> di
                 "fail_count": sf,
                 "success_count": su,
                 "diff_count": sf,
-                "pass_rate": round((su / sj) * 100, 1) if sj else (100.0 if st == 0 else 0.0),
+                # Pending sheets must not look like "100% pass"
+                "pass_rate": None
+                if pending
+                else (round((su / sj) * 100, 1) if sj else (100.0 if st == 0 else 0.0)),
             }
         )
 
@@ -2201,6 +2347,9 @@ def _enrich_summary(summary: dict[str, Any], sheets: list[dict[str, Any]]) -> di
             key=lambda x: (-int(x["count"]), str(x["field"])),
         )[:8]
 
+    any_pending = any(
+        str(sh.get("status") or "") in ("pending", "running", "queued") for sh in sheets
+    )
     return {
         "added": added,
         "removed": removed,
@@ -2214,9 +2363,9 @@ def _enrich_summary(summary: dict[str, Any], sheets: list[dict[str, Any]]) -> di
         "fail_count": fail_count,
         "success_count": success_count,
         "diff_count": diff_count,
-        "pass_rate": pass_rate,
+        "pass_rate": None if any_pending else pass_rate,
         "diff_rate": diff_rate,
-        "ok": fail_count == 0,
+        "ok": False if any_pending else fail_count == 0,
         "sheet_cards": sheet_cards,
         "top_changed_fields": top_fields,
         "duration_ms": int(summary.get("duration_ms") or 0),
@@ -2248,6 +2397,7 @@ def get_run(db: Session, run_id: str) -> dict[str, Any]:
             "display_fields": list(sh.get("display_fields") or []),
             "field_rules": list(sh.get("field_rules") or []),
             "mode": sh.get("mode") or ("presence" if not sh.get("compare_fields") else "fields"),
+            "status": str(sh.get("status") or "done"),
             "summary": dict(sh.get("summary") or {}),
         }
         for sh in raw_sheets

web/src/i18n/en.ts

@@ -500,6 +500,8 @@ const en = {
     runStatusFailed: "Failed",
     runStatusDoneSec: "Done {{s}}s",
     runProgress: "{{phase}} · sheet {{i}}/{{n}} · {{sheet}} · {{s}}s elapsed",
+    runRowsLoaded: "Loaded {{side}} {{n}} rows",
+    sheetPending: "Pending",
     ranWithDuration: "Compare finished ({{s}}s)",
     unchangedNotStored: "Success rows were counted but not stored. Set “Store success rows” to sample and re-run for spot-check.",
     unchangedSampleHint: "{{total}} success rows total; browsing a sample of {{listed}} (hydrated from source tables for cutover spot-check). Pass rate uses all {{total}}.",

web/src/i18n/zh.ts

@@ -499,6 +499,8 @@ const zh = {
     runStatusFailed: "失败",
     runStatusDoneSec: "完成 {{s}}s",
     runProgress: "{{phase}} · 表 {{i}}/{{n}} · {{sheet}} · 已用 {{s}}s",
+    runRowsLoaded: "已加载 {{side}} {{n}} 行",
+    sheetPending: "等待中",
     ranWithDuration: "比对完成（耗时 {{s}} 秒）",
     unchangedNotStored: "成功行仅统计数量未落库。可在任务配置将「成功行保存」改为抽样后重新比对（抽查用）。",
     unchangedSampleHint: "成功共 {{total}} 条，明细抽样 {{listed}} 条（从原表补全显示，割接抽查用）。通过率按全部 {{total}} 计。",

web/src/index.css

@@ -12152,6 +12152,15 @@ body:has(.bs-cmp-board:fullscreen) {
   box-shadow: 0 0 0 2px rgba(245, 158, 11, 0.22);
 }
 
+.bs-cmp-nav__item.is-pending .bs-cmp-nav__dot {
+  background: #64748b;
+  box-shadow: 0 0 0 2px rgba(100, 116, 139, 0.25);
+}
+
+.bs-cmp-nav__item.is-pending .bs-cmp-nav__name {
+  opacity: 0.75;
+}
+
 .bs-cmp-nav__name {
   font-size: 12px;
   font-weight: 600;

web/src/pages/network/BizComparePage.tsx

@@ -1198,7 +1198,8 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
     Number(c.success_count ?? c.unchanged ?? 0);
 
   const sheetPassRateOf = (c: {
-    pass_rate?: number;
+    pass_rate?: number | null;
+    status?: string;
     fail_count?: number;
     diff_count?: number;
     removed?: number;
@@ -1206,7 +1207,10 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
     success_count?: number;
     unchanged?: number;
     added?: number;
-  }) => {
+  }): number | null => {
+    const st = String(c.status || "");
+    if (st === "pending" || st === "running" || st === "queued") return null;
+    if (c.pass_rate === null) return null;
     // Always recompute from fail/success so added never skews pass rate
     const fail = sheetFailOf(c);
     const ok = sheetSuccessOf(c);
@@ -1222,6 +1226,7 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
       title?: string;
       metric_id: string;
       mode?: string;
+      status?: string;
       added?: number;
       removed?: number;
       changed?: number;
@@ -1231,10 +1236,13 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
       fail_count?: number;
       success_count?: number;
       diff_count?: number;
-      pass_rate?: number;
+      pass_rate?: number | null;
     }>;
-    // Failures first so ops can scan quickly when many sheets
+    // Failures first; keep pending/running at the end so completed fails stay visible
     return [...raw].sort((a, b) => {
+      const pa = ["pending", "running", "queued"].includes(String(a.status || "")) ? 1 : 0;
+      const pb = ["pending", "running", "queued"].includes(String(b.status || "")) ? 1 : 0;
+      if (pa !== pb) return pa - pb;
       const da = sheetFailOf(a);
       const db = sheetFailOf(b);
       if (da !== db) return db - da;
@@ -1245,6 +1253,9 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
   const activeFail = sheetFailOf(activeSheetCard || {});
   const activeSuccess = sheetSuccessOf(activeSheetCard || {});
   const activePassRate = sheetPassRateOf(activeSheetCard || {});
+  const activeSheetPending = ["pending", "running", "queued"].includes(
+    String(activeSheetCard?.status || ""),
+  );
   const activeAdded = Number(activeSheetCard?.added || 0);
   const showFailCol =
     kindFilter === "diff" || kindFilter === "all" || kindFilter === "added";
@@ -1868,6 +1879,8 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
     before_count?: number;
     after_count?: number;
     diff_rows?: number;
+    load_side?: string;
+    rows_loaded?: number;
   };
 
   // Poll active compare runs so the modal can be closed and reopened safely.
@@ -3020,6 +3033,14 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                       s: String(Math.round(Number(runProgress.elapsed_ms || 0) / 1000)),
                     })}
                   </span>
+                  {Number(runProgress.rows_loaded || 0) > 0 ? (
+                    <span className="muted">
+                      {t("bizCompare.runRowsLoaded", {
+                        side: String(runProgress.load_side || "—"),
+                        n: String(runProgress.rows_loaded || 0),
+                      })}
+                    </span>
+                  ) : null}
                   {runDetail.message ? (
                     <span className="muted bs-cmp-progress__msg">{String(runDetail.message)}</span>
                   ) : null}
@@ -3098,11 +3119,14 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                             const unchanged = Number(s.summary?.unchanged || 0);
                             const fail = removed + changed;
                             const judged = fail + unchanged;
+                            const st = String((s as any).status || "done");
+                            const pending = ["pending", "running", "queued"].includes(st);
                             return {
                               sheet_id: sheetIdentity(s),
                               title: sheetLabel(s),
                               metric_id: s.metric_id,
                               mode: s.mode,
+                              status: st,
                               added: s.summary?.added,
                               removed,
                               changed,
@@ -3112,9 +3136,11 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                               fail_count: fail,
                               success_count: unchanged,
                               diff_count: fail,
-                              pass_rate: judged
-                                ? Math.round((unchanged / judged) * 1000) / 10
-                                : 100,
+                              pass_rate: pending
+                                ? null
+                                : judged
+                                  ? Math.round((unchanged / judged) * 1000) / 10
+                                  : 100,
                             };
                           })
                       ).map((c) => {
@@ -3124,6 +3150,9 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                         const id = sheetIdentity(c);
                         const label = sheetLabel(c);
                         const active = resultSheetId === id;
+                        const pending = ["pending", "running", "queued"].includes(
+                          String((c as any).status || ""),
+                        );
                         return (
                           <button
                             key={id}
@@ -3131,10 +3160,14 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                             role="tab"
                             aria-selected={active}
                             className={`bs-cmp-nav__item${active ? " is-active" : ""}${
-                              fail > 0 ? " has-diff" : " is-clean"
+                              pending ? " is-pending" : fail > 0 ? " has-diff" : " is-clean"
                             }`}
                             onClick={() => setResultSheetId(id)}
-                            title={`${label} · ${t("bizCompare.kindFail")} ${fail} · ${t("bizCompare.kindSuccess")} ${ok} · ${t("bizCompare.passRateShort")} ${rate}%`}
+                            title={
+                              pending
+                                ? `${label} · ${t("bizCompare.sheetPending")}`
+                                : `${label} · ${t("bizCompare.kindFail")} ${fail} · ${t("bizCompare.kindSuccess")} ${ok} · ${t("bizCompare.passRateShort")} ${rate}%`
+                            }
                           >
                             <span className="bs-cmp-nav__dot" aria-hidden />
                             <span className="bs-cmp-nav__name">{label}</span>
@@ -3144,13 +3177,13 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                                   fail > 0 ? " is-hot" : ""
                                 }`}
                               >
-                                {fail}
+                                {pending ? "—" : fail}
                               </span>
                               <span className="bs-cmp-nav__num bs-cmp-nav__num--ok is-hot">
-                                {ok}
+                                {pending ? "—" : ok}
                               </span>
                               <span className="bs-cmp-nav__num bs-cmp-nav__num--rate">
-                                {rate}%
+                                {pending || rate === null ? "…" : `${rate}%`}
                               </span>
                             </span>
                           </button>
@@ -3161,7 +3194,13 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
 
                   <div className="bs-cmp-main">
                     <div
-                      className={`bs-cmp-strip${activeFail > 0 ? " is-warn" : " is-ok"}`}
+                      className={`bs-cmp-strip${
+                        activeSheetPending
+                          ? " is-pending"
+                          : activeFail > 0
+                            ? " is-warn"
+                            : " is-ok"
+                      }`}
                     >
                       <div className="bs-cmp-strip__sheet">
                         <span className="bs-cmp-strip__sheet-tag">
@@ -3174,18 +3213,28 @@ export function BizComparePage({ pageMode = "all" }: { pageMode?: BizComparePage
                           {sheetLabel(activeSheetCard)}
                         </strong>
                         <span className="muted bs-cmp-strip__sheet-mode">
-                          {activeFail > 0 ? t("bizCompare.kindFail") : t("bizCompare.kindPass")}
+                          {activeSheetPending
+                            ? t("bizCompare.sheetPending")
+                            : activeFail > 0
+                              ? t("bizCompare.kindFail")
+                              : t("bizCompare.kindPass")}
                           {activeSheetCard?.mode === "presence"
                             ? ` · ${t("bizCompare.presenceShort")}`
                             : ""}
-                          {` · ${activeSheetCard?.before_count ?? 0}→${activeSheetCard?.after_count ?? 0}`}
+                          {activeSheetPending
+                            ? ""
+                            : ` · ${activeSheetCard?.before_count ?? 0}→${activeSheetCard?.after_count ?? 0}`}
                         </span>
                       </div>
                       <div className="bs-cmp-strip__pass" title={t("bizCompare.passRate")}>
                         <span className="bs-cmp-strip__pass-label">
                           {t("bizCompare.passRate")}
                         </span>
-                        <span className="bs-cmp-strip__pass-value">{activePassRate}%</span>
+                        <span className="bs-cmp-strip__pass-value">
+                          {activeSheetPending || activePassRate === null
+                            ? "…"
+                            : `${activePassRate}%`}
+                        </span>
                       </div>
                       <div className="bs-cmp-strip__kinds" role="group">
                         {(