Skip to content

Make expired-task cleanup atomic#373

Open
aaroncoville wants to merge 1 commit intocloseio:masterfrom
aaroncoville:fix-atomic-expiry
Open

Make expired-task cleanup atomic#373
aaroncoville wants to merge 1 commit intocloseio:masterfrom
aaroncoville:fix-atomic-expiry

Conversation

@aaroncoville
Copy link
Copy Markdown

@aaroncoville aaroncoville commented Apr 21, 2026

Replace the GET + _move() combination in
Worker._worker_queue_expired_tasks with a single Lua EVAL (HANDLE_EXPIRED_TASK).

  • Closes an author-flagged race window (# XXX: Ideally, the following block should be atomic. in Worker._worker_queue_expired_tasks).
  • It does not include a test that fails on master. I tried.

If the reviewers don't want to accept the change without it being reproducible, I understand — let me know and I can put more time into trying to trigger the race window.

Replace the GET + _move() combination in
Worker._worker_queue_expired_tasks with a single Lua EVAL
(HANDLE_EXPIRED_TASK).
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant