Logflare / logflare / c015f9fcf8128585a1bebe8f696f86c52b072802-PR-3616

81%

main: 82%

Build Type

Pull #3616

github

Committed by djwhitt

Commit Message

test(ingest): cover claim-reset reclaim cycle and process_data source threading

Adds behavioral coverage for the two changes that previously only had static
or indirect assertions:

- take_pending_ids/2: an event re-added after being claimed is claimable
  again, proving the claim counter resets on re-insert.
- QueueJanitor: a stale :processing event reset to :pending can be re-claimed
  by take_pending_ids (real claim -> stale-reset -> re-claim cycle), tying the
  janitor reset to actual claimability rather than just asserting claim == 0.
- process_data/3: the schema-update decision uses the threaded source —
  skipped when lock_schema is set, run with the passed source otherwise, and
  no crash when the source is nil.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Pull Request Pull Request #3616: perf(ingest): update_counter claim + BigQuery pipeline allocation cleanups

Coverage Stats

30 of 33 new or added lines in 4 files covered. (90.91%)

26 existing lines in 6 files now uncovered.

13215 of 16289 relevant lines covered (81.13%)

5208.7 hits per line