how can we ensure each job is consumed at least once? about solid_queue HOT 2 CLOSED

Hey @mxchenxiaodong, thank you! There's a brief explanation about this in the README:

If processes have no chance of cleaning up before exiting (e.g. if someone pulls a cable somewhere), in-flight jobs might remain claimed by the processes executing them. Processes send heartbeats, and the supervisor checks and prunes processes with expired heartbeats, which will release any claimed jobs back to their queues. You can configure both the frequency of heartbeats and the threshold to consider a process dead. See the section below for this.

When you start a new supervisor, or simply periodically, the supervisor checks for processes that have died and deregister them. Deregistering a process releases its claimed executions. Also, claimed executions have their own release method. Yours doesn't work because the job is already in the system and you can't just enqueue it again.

from solid_queue.

I understand now, thank you for the explanation~ @rosa

app/models/solid_queue/process.rb

class SolidQueue::Process < SolidQueue::Record
  after_destroy -> { claimed_executions.release_all }
end

😆

from solid_queue.