diff options
| author | pechatnov <[email protected]> | 2026-07-07 08:34:32 +0300 |
|---|---|---|
| committer | pechatnov <[email protected]> | 2026-07-07 09:01:49 +0300 |
| commit | 5dd5eeeb003bd12735db1c23254407d24d7124ee (patch) | |
| tree | aa6f1e05d11e8260d2d6d7034126ab53e9935c68 /contrib/python/ipython/py2/IPython/utils/pickleutil.py | |
| parent | 41faac0906f3d43235e5da203bf09a32eb5292be (diff) | |
Cancel jobs instead of dropping them on controller loss
A worker that stays without controller heartbeats longer than controller_wait_timeout now cancels its jobs with a typed AbandonedJob error and keeps their runtime records, instead of dropping them and restarting the same job ids in place (which silently lost accepted-but-unconfirmed input messages, leaving upstream distributors waiting forever). The controller learns about the cancelled jobs through regular status reports and recreates them with new ids without the failure backoff. The execution spec is no longer reset on disconnect, so the data plane keeps working while the controller is away.
Cancel jobs instead of dropping them on controller loss
commit_hash:faf38ecdc0637d5ee86d50de3b5e22d6e148ae70
Diffstat (limited to 'contrib/python/ipython/py2/IPython/utils/pickleutil.py')
0 files changed, 0 insertions, 0 deletions
