diff --git a/docs/tasks/lethe-collector-claude-code.md b/docs/tasks/lethe-collector-claude-code.md index f65da53a0e78c8b7f3f258bf81da02ae43f4ac16..757691c4206d864e3212b137ad72b2acfa53c468 100644 --- a/docs/tasks/lethe-collector-claude-code.md +++ b/docs/tasks/lethe-collector-claude-code.md @@ -305,7 +305,7 @@ - CK9 (IF2) — `state.Store` offset/outbox methods are exercised by runner and state tests. - CK10 (IF3) — `Sender.PostBatch(ctx, events)` is exercised by sender, outbox, and runner tests. - CK11 (IF4) — `RunOnce` / `RunDaemon` are exercised by CLI wiring and runner tests. -Smoke: `go run ./cmd/lethe-collector --config ./tmp/collector-smoke.yaml status` → prints host, state DB, outbox stats, and source list. +Smoke: `go run ./cmd/lethe-collector --config ./tmp/collector-smoke.yaml status` → prints host, state DB, outbox stats, source list, and `lag_bytes`. ## Conclusion @@ -318,10 +318,6 @@ - uplan: plan auto-approved (hands-off). - ureview (re-review): fixed `persistAcceptedOffset` to use the first error's `Line` (1-based within the request body) to identify the failed row, rather than assuming `result.Accepted` points to it. Valid but uncommitted rows before the failed line are re-posted as a smaller prefix before the failed row is skipped, preventing data loss when `accepted=0, errors line=2`. - ureview (re-review): added WARN log with dropped row count and bytes to `EnforceOutboxLimit`. - ureview (re-review): added `lag_bytes` per file to `status` output using `parser.SourceFile.Size` from discovery. - -### Deferred / known limitations - -- `status` does not display per-source `last_error` because the PH1 state schema (`ingestion_state` table) stores only `last_offset`, not error history or timestamps. Adding these requires a schema extension outside the current plan scope. ### Deferred (needs user input)