We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f0e2599 commit 6196aafCopy full SHA for 6196aaf
artiq/master/worker.py
@@ -41,7 +41,7 @@ def log_worker_exception():
41
42
43
class Worker:
44
- def __init__(self, handlers=dict(), send_timeout=1.0):
+ def __init__(self, handlers=dict(), send_timeout=2.0):
45
self.handlers = handlers
46
self.send_timeout = send_timeout
47
@@ -94,7 +94,7 @@ async def _create_process(self, log_level):
94
finally:
95
self.io_lock.release()
96
97
- async def close(self, term_timeout=1.0):
+ async def close(self, term_timeout=2.0):
98
"""Interrupts any I/O with the worker process and terminates the
99
worker process.
100
0 commit comments