Logflare / logflare / 08ec93c8feff1c1aa95ac000d058ed35e347cf05-PR-3617

81%

main: 82%

Build Type

Pull #3617

github

Committed by djwhitt

Commit Message

fix(ingest queue): reset claim counter when update_status sets :pending

update_status/3 accepts :pending but only wrote the status field, so
using it to requeue a claimed row would leave claim == 1 and strand the
row as unclaimable. Reset field 5 to 0 in the same atomic update_element
call when setting :pending, matching the invariant add_to_table/3 and the
QueueJanitor reset already uphold. Also correct the claim_pending/2
invariant comment: the counter bump is the atomic election, but the
follow-up :processing status write is a separate, non-atomic step.

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

Pull Request Pull Request #3617: perf(ingest): claim pending events via an atomic claim counter

Coverage Stats

11 of 13 new or added lines in 3 files covered. (84.62%)

19 existing lines in 1 file now uncovered.

13230 of 16294 relevant lines covered (81.2%)

5170.79 hits per line