diff --git a/bonobo/execution/contexts/node.py b/bonobo/execution/contexts/node.py index 784dd8f..4c5cff7 100644 --- a/bonobo/execution/contexts/node.py +++ b/bonobo/execution/contexts/node.py @@ -123,8 +123,6 @@ class NodeExecutionContext(BaseContext, WithStatistics): self.step() except InactiveReadableError: break - except Empty: - sleep(TICK_PERIOD) # XXX: How do we determine this constant? logger.debug('Node loop ends for {!r}.'.format(self)) @@ -133,6 +131,8 @@ class NodeExecutionContext(BaseContext, WithStatistics): self._step() except InactiveReadableError: raise + except Empty: + sleep(TICK_PERIOD) # XXX: How do we determine this constant? except ( NotImplementedError, UnrecoverableError,