live pipeline updates during scan via SSE pipeline_changed events
Build and Push Docker Image / build (push) Successful in 38s

scan emits pipeline_changed every 25 items, rescan endpoints emit on
completion. pipeline page listens and throttle-reloads all column data
(1s debounce) so inbox fills progressively without manual navigation.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
This commit is contained in:
2026-04-20 10:57:01 +02:00
parent ce37aec647
commit b7f6144a6a
4 changed files with 15 additions and 2 deletions
+6
View File
@@ -154,6 +154,12 @@ export function emitInboxSortProgress(processed: number, total: number): void {
for (const l of jobListeners) l(line);
}
/** Lightweight nudge so the pipeline page refreshes column data. */
export function emitPipelineChanged(): void {
const line = "event: pipeline_changed\ndata: {}\n\n";
for (const l of jobListeners) l(line);
}
/**
* If the queue runner is idle and the auto_process_queue config is on, kick
* off a sequential pass over whatever's currently pending. Used by the