From ae5ce01f4faf666c5426cb0e047b3aa7ac10583b Mon Sep 17 00:00:00 2001
From: Lars Wirzenius <liw@liw.fi>
Date: Sun, 21 Jan 2018 17:44:51 +0200
Subject: Add: add timeout flushing of buffers

---
 worker_manager | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'worker_manager')

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()
-- 
cgit v1.2.1