diff options
| author | Joshua Harlow <harlowja@gmail.com> | 2014-10-18 19:22:08 -0700 |
|---|---|---|
| committer | Joshua Harlow <harlowja@yahoo-inc.com> | 2014-10-21 15:37:44 -0700 |
| commit | 3c9871d8c3e5746db23a8749df0123818c6d9f55 (patch) | |
| tree | f48c3acc3960512fc866e647d068505b7cde8ff1 /taskflow/engines/worker_based/executor.py | |
| parent | 58f27fcd2d7d3206477cbf58e851ba208ba38975 (diff) | |
| download | taskflow-3c9871d8c3e5746db23a8749df0123818c6d9f55.tar.gz | |
Remove direct usage of the deprecated failure location
Internally we should be using the new location and not the
deprecated location wherever possible. This avoids emitting
warnings messages on our own code, which is a dirty habit.
Change-Id: Idac5a772eca7529d92542ada3be1cea092880e25
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.""" |