-
최근 24시간
- {#if pipelineRows.length > 0}
-
- {#each pipelineRows as row (row.stage)}
-
-
-
- {row.label}
- {#if row.oldestPendingAgeSec && row.oldestPendingAgeSec > 600}
- ({formatAge(row.oldestPendingAgeSec)})
- {/if}
-
-
- 대기 {row.pending} ·
- 처리 {row.processing} ·
- 실패 0 ? 'text-error font-medium' : ''}>{row.failed}
-
+ {#if queue}
+ {#if activeStageRows.length > 0}
+
+ {#each activeStageRows as row (row.stage)}
+ {@const total = row.done_today + row.pending + row.processing}
+ {@const donePct = total > 0 ? (row.done_today / total) * 100 : 0}
+ {@const procPct = total > 0 ? (row.processing / total) * 100 : 0}
+
+
+
+ {queueStageLabel(row.stage)}
+ {#if row.processing > 0}
+
+ 처리 중 {row.processing}
+ {/if}
+
+
+ {#if row.done_today > 0}오늘 {row.done_today.toLocaleString()} 완료{/if}
+ {#if row.pending > 0}대기 {row.pending.toLocaleString()}{/if}
+ {#if row.failed > 0}실패 {row.failed}{/if}
+
+
+
+
+ {#if donePct > 0}
{/if}
+ {#if procPct > 0}
{/if}
+
+ {#if row.pending > 0 && row.oldest_pending_age_sec && row.oldest_pending_age_sec > 600}
+
+ 가장 오래 기다린 항목 {formatAge(row.oldest_pending_age_sec)}
+
+ {/if}
-
- {#if row.pending > 0}
{/if}
- {#if row.processing > 0}
{/if}
- {#if row.failed > 0}
{/if}
-
-
- {/each}
-
+ {/each}
+
+ {:else}
+
대기·처리·실패 없음 — 모든 단계가 한가합니다
+ {/if}
+ {#if idleStageRows.length > 0}
+
+ 비어 있음: {idleStageRows.map((r) => queueStageLabel(r.stage)).join(' · ')}
+
+ {/if}
{:else}
-
처리 작업 없음
+
현황을 불러오지 못했습니다
{/if}
diff --git a/tests/test_queue_overview.py b/tests/test_queue_overview.py
index 9db1e42..03fde17 100644
--- a/tests/test_queue_overview.py
+++ b/tests/test_queue_overview.py
@@ -329,7 +329,7 @@ def test_compose_overview_contract_shape():
deep_enabled=True,
now_kst=datetime(2026, 6, 11, 14, 30, tzinfo=KST),
)
- assert set(out.keys()) == {"machines", "summarize_eta", "trend_24h", "totals"}
+ assert set(out.keys()) == {"machines", "stages", "summarize_eta", "trend_24h", "totals"}
assert [m["key"] for m in out["machines"]] == ["gpu", "macmini", "macbook"]
for m in out["machines"]:
assert set(m.keys()) == {
@@ -343,3 +343,28 @@ def test_compose_overview_contract_shape():
assert set(out["totals"].keys()) == {"pending", "processing", "failed"}
# 머신 label 고정 (raw 모델명 노출 금지 — label 만)
assert [m["label"] for m in out["machines"]] == ["GPU 서버", "맥미니", "맥북 M5 Max"]
+
+
+# ─── build_stages (단계별 현황 — 2026-06-11 사용자 피드백: 완료 가시화) ──────
+
+def test_build_stages_order_fields_and_age():
+ from datetime import timedelta, timezone
+ from services.queue_overview import build_stages
+ now = datetime(2026, 6, 11, 14, 0, tzinfo=timezone.utc)
+ stats = {
+ "summarize": {**_stage(pending=5, done_today=12),
+ "oldest_pending_at": now - timedelta(hours=4)},
+ "extract": _stage(failed=2),
+ }
+ rows = build_stages(stats, now=now)
+ by = {r["stage"]: r for r in rows}
+ # 파이프라인 순서: extract 가 summarize 보다 앞
+ assert rows[0]["stage"] == "extract"
+ assert by["summarize"]["pending"] == 5
+ assert by["summarize"]["done_today"] == 12
+ assert by["summarize"]["oldest_pending_age_sec"] == 4 * 3600
+ assert by["extract"]["failed"] == 2
+ assert by["extract"]["oldest_pending_age_sec"] is None
+ # 전 stage 행 존재 (빈 단계 숨김은 FE 몫)
+ assert {"stage", "pending", "processing", "failed", "done_today",
+ "oldest_pending_age_sec"} == set(rows[0].keys())