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()