Revise job recovery behavior.
- Fix bug where jobs may have been recovered before the MQ callback was set on the manager. - Add a new LOST job state for jobs that cannot be recovered and the Pulsar is going to abandon. - Fire off callback for LOST jobs. - Add test case to verify callback is called for LOST jobs.
Showing
- pulsar/core.py 5 additions, 0 deletionspulsar/core.py
- pulsar/managers/base/external.py 5 additions, 2 deletionspulsar/managers/base/external.py
- pulsar/managers/stateful.py 19 additions, 6 deletionspulsar/managers/stateful.py
- pulsar/managers/status.py 12 additions, 1 deletionpulsar/managers/status.py
- test/integration_test_restart.py 63 additions, 13 deletionstest/integration_test_restart.py
- test/persistence_test.py 1 addition, 0 deletionstest/persistence_test.py
Loading
Please register or sign in to comment