fix: kill process when timeout 1min

manatlan · Oct 8, 2023 · 5ee5394 · 5ee5394
1 parent 9bead55
commit 5ee5394
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/htagweb/server/client.py b/htagweb/server/client.py
@@ -11,11 +11,11 @@
 import uuid,asyncio,time,sys
 import redys
 import redys.v2
-from htagweb.server import CMD_RESP_RECREATE, CMD_RESP_RENDER, CMD_PS_REUSE, KEYAPPS,Hid, hrprocess
+from htagweb.server import CMD_RESP_RECREATE, CMD_RESP_RENDER, CMD_PS_REUSE, KEYAPPS,Hid, hrprocess, ServerClient
 import logging
 logger = logging.getLogger(__name__)
 
-TIMEOUT=2*60 # A interaction can take 2min max
+TIMEOUT=1*60 # A interaction can take 1min max
 
 
 def startProcess(params:dict):
@@ -87,8 +87,10 @@ async def start(self,*a,**k) -> str:
                     # the process has giver a right answer ... return the rendering
                     return message.get("render")
 
+
         self.error(f"Event TIMEOUT ({TIMEOUT}s) on {self.hid.event_response} !!!")
-        return "?!"
+        await ServerClient().kill(self.hid)
+        return f"Timeout: App {self.hid.fqn} killed !"
 
 
 
@@ -103,7 +105,7 @@ async def interact(self,**params) -> dict:
             # post the interaction
             if await self.bus.publish( self.hid.event_interact, params ):
                 # wait actions
-                return await self._wait(self.hid.event_interact_response) or {}
+                return await self._wait(self.hid.event_interact_response) or dict(error=f"Timeout: App {self.hid.fqn} killed !")
             else:
                 self.error(f"Can't publish {self.hid.event_interact} !!!")
         except Exception as e:
@@ -119,4 +121,5 @@ async def _wait(self,event, s=TIMEOUT):
                 return message
 
         self.error(f"Event TIMEOUT ({s}s) on {event} !!!")
+        await ServerClient().kill(self.hid)
         return None