diff options
Diffstat (limited to 'taskflow/engines/worker_based/executor.py')
| -rw-r--r-- | taskflow/engines/worker_based/executor.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/taskflow/engines/worker_based/executor.py b/taskflow/engines/worker_based/executor.py index 235f3c9..ae8e0e4 100644 --- a/taskflow/engines/worker_based/executor.py +++ b/taskflow/engines/worker_based/executor.py @@ -172,9 +172,9 @@ class WorkerTaskExecutor(executor.TaskExecutorBase): " seconds for it to transition out of (%s) states" % (request, request_age, ", ".join(pr.WAITING_STATES))) except exc.RequestTimeout: - with misc.capture_failure() as fail: - LOG.debug(fail.exception_str) - request.set_result(fail) + with misc.capture_failure() as failure: + LOG.debug(failure.exception_str) + request.set_result(failure) def _on_wait(self): """This function is called cyclically between draining events.""" |