Skip to content

v0.2.8

Choose a tag to compare

@danish-a1 danish-a1 released this 22 Oct 15:45
· 27 commits to main since this release

Added

  • Reclaim jobs left behind by a crashed process. A Redis job sits in processing:<queue> while a worker runs it. If the process is killed (SIGKILL, OOM, host loss), the job used to stay there and never run again. Config.WithReclaimProcessingOnStart(true) now moves those jobs back onto the queue when StartWorkers runs.
    • Opt-in: only enable it when a single consumer instance serves the queue. With several instances it would also move jobs another instance is still running.
    • Stores without a processing list are skipped; a reclaim failure is logged and does not stop the workers.