Merge "catch NotFound errors when consuming or abandoning"

2015-02-15 05:25:13 +00:00
parent 4d3b84f960 073eb325b6
commit 5ee7e94e5e
1 changed files with 1 additions and 1 deletions
--- 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)