srenblad
/
artiq
forked from M-Labs/artiq
1
0
Fork 0
Code Pull Requests Activity

worker: reduce some logging levels

This commit is contained in:
Sebastien Bourdeauducq 2015-10-29 09:34:41 +08:00
parent c0e040c4b9
commit 32c95f24d0
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
artiq/master/worker.py
View File

@ -92,8 +92,8 @@ class Worker:
try: try:
await self._send(obj, cancellable=False) await self._send(obj, cancellable=False)
except: except:
logger.warning("failed to send terminate command to worker" logger.debug("failed to send terminate command to worker"
" (RID %s), killing", self.rid, exc_info=True) " (RID %s), killing", self.rid, exc_info=True)
try: try:
self.process.kill() self.process.kill()
except ProcessLookupError: except ProcessLookupError:
@ -103,14 +103,15 @@ class Worker:
try: try:
await asyncio.wait_for(self.process.wait(), term_timeout) await asyncio.wait_for(self.process.wait(), term_timeout)
except asyncio.TimeoutError: except asyncio.TimeoutError:
logger.warning("worker did not exit (RID %s), killing", self.rid) logger.debug("worker did not exit by itself (RID %s), killing",
self.rid)
try: try:
self.process.kill() self.process.kill()
except ProcessLookupError: except ProcessLookupError:
pass pass
await self.process.wait() await self.process.wait()
else: else:
logger.debug("worker exited gracefully (RID %s)", self.rid) logger.debug("worker exited by itself (RID %s)", self.rid)
finally: finally:
self.io_lock.release() self.io_lock.release()