diff options
| author | Jenkins <jenkins@review.openstack.org> | 2015-02-15 05:25:13 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2015-02-15 05:25:13 +0000 |
| commit | 5ee7e94e5ecbbfae90e969f040e4c5b6d31d3dfa (patch) | |
| tree | 6852e12d285871608d248736958f48a425d8c5de | |
| parent | 4d3b84f9606ea712c980466f4a425b546f71337c (diff) | |
| parent | 073eb325b6870edf100e3780540e921cc5e56496 (diff) | |
| download | taskflow-5ee7e94e5ecbbfae90e969f040e4c5b6d31d3dfa.tar.gz | |
Merge "catch NotFound errors when consuming or abandoning"
| -rw-r--r-- | taskflow/conductors/single_threaded.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/taskflow/conductors/single_threaded.py b/taskflow/conductors/single_threaded.py index 2304514..a52dc34 100644 --- a/taskflow/conductors/single_threaded.py +++ b/taskflow/conductors/single_threaded.py @@ -148,7 +148,7 @@ class SingleThreadedConductor(base.Conductor): self._jobboard.consume(job, self._name) else: self._jobboard.abandon(job, self._name) - except excp.JobFailure: + except (excp.JobFailure, excp.NotFound): if consume: LOG.warn("Failed job consumption: %s", job, exc_info=True) |