diff --git a/taskflow/conductors/single_threaded.py b/taskflow/conductors/single_threaded.py index 23045146..a52dc347 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)