Skip to content

GH-2222: Expand dispatcher recovery + add periodic loop (internal/executor/) - In internal/executor/dispatcher.go: (a) Add StaleRunningThreshold, StaleQueuedThreshold, and StaleRecoveryInterval fields to DispatcherConfig (keeping StaleTaskDuration as backwards-compat alias for StaleRunningThreshold, defaults: 30min running, 5min queued, 5min interval). (b) Rewrite recoverStaleTasks() to recover both running and queued orphans, marking them failed (not re-queued #2224

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
alekspetrov wants to merge 1 commit into from

GH-2222: feat(executor): add periodic stale task recovery to dispatcher

701c36a
Select commit
Loading
Failed to load commit list.

Workflow runs completed with no jobs