reset retries with each new job
This commit is contained in:
parent
b31f546516
commit
7f099c02e5
|
@ -49,6 +49,7 @@ class WorkerContext:
|
|||
|
||||
def start(self, job: str) -> None:
|
||||
self.job = job
|
||||
self.retries = 3
|
||||
self.set_cancel(cancel=False)
|
||||
self.set_idle(idle=False)
|
||||
|
||||
|
|
Loading…
Reference in New Issue