Now sending is alive message every 1 minute.

kube-HPC · Sep 4, 2024 · 88d6702 · 88d6702
1 parent 6ce748c
commit 88d6702
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/hkube_python_wrapper/wrapper/wc.py b/hkube_python_wrapper/wrapper/wc.py
@@ -21,7 +21,8 @@ def __init__(self, msg_queue, encoding, url):
         self._active = True
         self._firstConnect = False
         self._printThrottleMessages = {
-            messages.outgoing.streamingStatistics: {"delay": 240, "lastPrint": None}
+            messages.outgoing.streamingStatistics: {"delay": 240, "lastPrint": None},
+            messages.outgoing.alive: {"delay": 60, "lastPrint": None}
         }
         self._encoding = Encoding(encoding)
         self._ws_opcode = ABNF.OPCODE_BINARY if self._encoding.isBinary else ABNF.OPCODE_TEXT