Reset the failure flag in workers on successful runs. #76
@ -66,6 +66,12 @@ public abstract class AbstractWorker implements Worker {
|
|||||||
// Now that they're singletons the field is never reset to true after a
|
// Now that they're singletons the field is never reset to true after a
|
||||||
// failure and the worker will be stuck in a failed state even after a
|
// failure and the worker will be stuck in a failed state even after a
|
||||||
// subsequent successful run.
|
// subsequent successful run.
|
||||||
|
//
|
||||||
|
// TODO:
|
||||||
|
// In the future this flag should be removed and any execution that does
|
||||||
|
// not throw an exception should be considered successful.
|
||||||
|
// If a worker needs to signal a non-exception as a failure that should
|
||||||
|
// be an internal matter and not something the scheduler should consider.
|
||||||
setSuccessfulWorker(true);
|
setSuccessfulWorker(true);
|
||||||
|
|
||||||
doWork();
|
doWork();
|
||||||
|
Loading…
x
Reference in New Issue
Block a user