From 8edd395ff6679feb24e3609c9a756e0ce97d5d47 Mon Sep 17 00:00:00 2001 From: Aditya <60684641+0x0elliot@users.noreply.github.com> Date: Fri, 3 Nov 2023 03:35:36 +0530 Subject: [PATCH] fix: Adding SHUFFLE_APP_SDK_TIMEOUT --- backend/app_sdk/app_base.py | 6 ++++++ functions/onprem/worker/worker.go | 1 + 2 files changed, 7 insertions(+) diff --git a/backend/app_sdk/app_base.py b/backend/app_sdk/app_base.py index f19b0f2c..f7452ab4 100755 --- a/backend/app_sdk/app_base.py +++ b/backend/app_sdk/app_base.py @@ -3519,6 +3519,12 @@ class AppBase: if self.action["app_name"].lower() == "shuffle tools": timeout = 55 + timeout_env = os.getenv("SHUFFLE_APP_SDK_TIMEOUT", timeout) + try: + timeout = int(timeout_env) + except Exception as e: + self.logger.info(f"[WARNING] Failed parsing timeout to int: {e}") + #timeout = 30 try: diff --git a/functions/onprem/worker/worker.go b/functions/onprem/worker/worker.go index 427a4bee..8fb68483 100755 --- a/functions/onprem/worker/worker.go +++ b/functions/onprem/worker/worker.go @@ -230,6 +230,7 @@ func deployApp(cli *dockerclient.Client, image string, identifier string, env [] // log.Printf("image: %s", image) // log.Printf("identifier: %s", identifier) // log.Printf("execution: %+v", workflowExecution) + env = append(env, fmt.Sprintf("SHUFFLE_APP_SDK_TIMEOUT=%s", os.Getenv("SHUFFLE_APP_SDK_TIMEOUT"))) if os.Getenv("IS_KUBERNETES") == "true" {