From 761d7d4c0605a148b8ee0e6a04a44177160a335c Mon Sep 17 00:00:00 2001
From: Tristan Cacqueray <tdecacqu@redhat.com>
Date: Jan 05 2021 15:51:18 +0000
Subject: Increase stalled timeout to 6 hours


This change prevents job from failing if a command doesn't output
anything for more than one hour.

---

diff --git a/k1s/api.py b/k1s/api.py
index bed481b..31d39a2 100644
--- a/k1s/api.py
+++ b/k1s/api.py
@@ -150,6 +150,10 @@ def terminate(proc: Proc) -> None:
         pass
 
 
+def stalled(idle_time: float) -> bool:
+    return time.monotonic() - idle_time > 21600 # 6 hours
+
+
 def run_port_forwards(name: str, spdy: SPDYHandler) -> None:
     streams: Dict[int, Stream] = dict()
     unblock_file(spdy.sock)
@@ -161,7 +165,7 @@ def run_port_forwards(name: str, spdy: SPDYHandler) -> None:
                 if proc:
                     readers.extend([proc.stdout, proc.stderr])
             r, w, x = select.select(readers, [], [], 1)
-            if time.monotonic() - idle_time > 3600:
+            if stalled(idle_time):
                 log.error("ERROR: process stalled")
                 break
             for reader in r:
@@ -219,7 +223,7 @@ def run_exec_stream(proc: Proc, spdy: SPDYHandler) -> int:
             r, w, x = select.select(
                 [proc.stdout, proc.stderr, spdy.sock], [], [], 1)
             # print("Select yield", r)
-            if time.monotonic() - idle_time > 3600:
+            if stalled(idle_time):
                 log.error("ERROR: process stalled")
                 break
             for reader in r:
diff --git a/setup.py b/setup.py
index e52eb05..f670a08 100644
--- a/setup.py
+++ b/setup.py
@@ -16,7 +16,7 @@ import setuptools
 
 setuptools.setup(
     name="k1s",
-    version="0.0.1",
+    version="0.1.0",
     author="Tristan de Cacqueray",
     author_email="tdecacqu@redhat.com",
     description="Minimal kubernetes service for nodepool",