Unverified Commit 68c26dd4 authored by chicm-ms's avatar chicm-ms Committed by GitHub
Browse files

Fix dispatcher exception handling issue (#1018)

parent a46bf0d9
...@@ -77,6 +77,8 @@ class MsgDispatcherBase(Recoverable): ...@@ -77,6 +77,8 @@ class MsgDispatcherBase(Recoverable):
break break
else: else:
self.enqueue_command(command, data) self.enqueue_command(command, data)
if self.worker_exceptions:
break
_logger.info('Dispatcher exiting...') _logger.info('Dispatcher exiting...')
self.stopping = True self.stopping = True
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment