Commit 7d29936b authored by Samuel GAIST's avatar Samuel GAIST

[execution][local] Improve handling of message handler shutdown

Relates to beat.backend.python#30
parent 555309c5
Pipeline #36725 passed with stage
in 16 minutes and 5 seconds
......@@ -200,7 +200,12 @@ class LocalExecutor(BaseExecutor):
for handler in [self.message_handler, self.loop_message_handler]:
if handler:
handler.kill()
handler.join()
try:
handler.join()
except RuntimeError:
# The handler was not started
pass
handler.destroy()
for socket in [self.executor_socket, self.loop_socket]:
......
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