Skip to content

v1.0.11

Choose a tag to compare

@adhikjoshi adhikjoshi released this 26 Apr 07:50
· 25 commits to main since this release

Fixes for production stuck-task and queued_requests leak.

  • worker_loop: persist started_at on the Task object and write status='processing' to task:{id} so _store_final_task_state keeps them. Previously started_at was lost in the final stored record.
  • requeue_stuck_processing_tasks: fall back to queued_at when started_at is missing. Covers workers killed in the SADD processing_tasks → SET task:{id} window — those tasks were unrecoverable before.
  • _store_final_task_state: ZREM queued_requests on terminal state. Stops the unbounded zset growth (some clusters had reached >1M entries).