We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 50a6da9 commit c843c35Copy full SHA for c843c35
artiq/master/worker.py
@@ -101,17 +101,13 @@ def close(self):
101
logger.warning("failed to send terminate command to worker"
102
" (RID %d), killing", self.rid, exc_info=True)
103
self.process.kill()
104
- # Wait for process to terminate
105
- yield from self.process.communicate()
106
return
107
try:
108
yield from asyncio_process_wait_timeout(self.process,
109
self.term_timeout)
110
except asyncio.TimeoutError:
111
logger.warning("worker did not exit (RID %d), killing", self.rid)
112
113
114
115
else:
116
logger.debug("worker exited gracefully (RID %d)", self.rid)
117
finally:
0 commit comments