summaryrefslogtreecommitdiff
path: root/worker_manager
diff options
context:
space:
mode:
authorLars Wirzenius <liw@liw.fi>2018-01-21 17:44:51 +0200
committerLars Wirzenius <liw@liw.fi>2018-01-21 20:32:06 +0200
commitae5ce01f4faf666c5426cb0e047b3aa7ac10583b (patch)
tree21ad18f208f510a3ffd4c9b70187425e8c73b35c /worker_manager
parent1d24b573e8e25daa63f302d41ccff698f5c23d07 (diff)
downloadick2-ae5ce01f4faf666c5426cb0e047b3aa7ac10583b.tar.gz
Add: add timeout flushing of buffers
Diffstat (limited to 'worker_manager')
-rwxr-xr-xworker_manager2
1 files changed, 2 insertions, 0 deletions
diff --git a/worker_manager b/worker_manager
index 85cd2b2..4cb0635 100755
--- a/worker_manager
+++ b/worker_manager
@@ -340,6 +340,8 @@ class Runner:
argv,
stdout_callback=self.capture_stdout,
stderr=subprocess.STDOUT,
+ output_timeout=self._timeout,
+ timeout_callback=self.flush,
**kwargs
)
self.flush()