Commit c81ea087 authored by Yuxin Wu's avatar Yuxin Wu

Join ZMQ processes after temination (#562)

parent ac02c62f
......@@ -108,6 +108,7 @@ class _MultiProcessZMQDataFlow(DataFlow):
self.context.destroy(0)
for x in self._procs:
x.terminate()
x.join(5)
try:
print("{} successfully cleaned-up.".format(type(self).__name__))
except Exception:
......
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