mosaicstack/queue
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: atomic create/update and mget list #6

Merged
jason.woltje merged 1 commits from fix/atomic-and-list-perf into main 2026-03-06 19:05:19 +00:00
Conversation 0 Commits 1 Files Changed 3 +369 -44
jason.woltje commented 2026-03-06 19:05:13 +00:00
Owner
Copy Link

Fixes mosaic/queue#4

  • create(): SET NX + SADD wrapped in WATCH/MULTI/EXEC — atomic, crash-safe
  • list(): replaced N+1 GET calls with single mget pipeline
  • update(): routed through mutateTaskAtomically with status transition guard
  • mget() added to RedisTaskClient interface
  • Tests: concurrent create race, concurrent update race, list with mget
Fixes mosaic/queue#4 - create(): SET NX + SADD wrapped in WATCH/MULTI/EXEC — atomic, crash-safe - list(): replaced N+1 GET calls with single mget pipeline - update(): routed through mutateTaskAtomically with status transition guard - mget() added to RedisTaskClient interface - Tests: concurrent create race, concurrent update race, list with mget
jason.woltje added 1 commit 2026-03-06 19:05:13 +00:00
fix: atomic create/update and mget list 06d195394e
jason.woltje merged commit 13536c6472 into main 2026-03-06 19:05:19 +00:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
jason.woltje
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: mosaicstack/queue#6
Delete Branch "fix/atomic-and-list-perf"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?