bug: fix bad mistake in moving the "empty" catcher.

This commit is contained in:
Romain Dorgueil
2018-07-22 07:58:30 +02:00
parent 3b1fb2a39b
commit e0d714cbba

View File

@ -123,8 +123,6 @@ class NodeExecutionContext(BaseContext, WithStatistics):
self.step() self.step()
except InactiveReadableError: except InactiveReadableError:
break break
except Empty:
sleep(TICK_PERIOD) # XXX: How do we determine this constant?
logger.debug('Node loop ends for {!r}.'.format(self)) logger.debug('Node loop ends for {!r}.'.format(self))
@ -133,6 +131,8 @@ class NodeExecutionContext(BaseContext, WithStatistics):
self._step() self._step()
except InactiveReadableError: except InactiveReadableError:
raise raise
except Empty:
sleep(TICK_PERIOD) # XXX: How do we determine this constant?
except ( except (
NotImplementedError, NotImplementedError,
UnrecoverableError, UnrecoverableError,