Skip to content

Conversation

@bobvoorneveld
Copy link

Added the possibility for recovering stale jobs, for instance after a worker crashes or got killed without a nice SIGTERM.
When the worker starts, it will ask the provider to check on stale jobs, where it can be configured to:

  • Do no recovery at all
  • Set the timeout of the jobs to check (defaults to 5 minutes)
  • Set the interval on how often the stale jobs should be checked (defaults to 15s)

In the queues-redis-provider I've created an implementation, will create a PR there. The default implementation will do nothing, so other drivers can implement this logic to.

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