diff --git a/zetta_utils/cloud_management/resource_allocation/k8s/common.py b/zetta_utils/cloud_management/resource_allocation/k8s/common.py index b9c29646..e42cf9df 100644 --- a/zetta_utils/cloud_management/resource_allocation/k8s/common.py +++ b/zetta_utils/cloud_management/resource_allocation/k8s/common.py @@ -72,7 +72,7 @@ def get_mazepa_worker_command( command = "mazepa.run_worker" num_procs_line = "" semaphores_line = "" - idle_timeout_line = f"idle_timeout: {num_procs}\n" + idle_timeout_line = f"idle_timeout: {idle_timeout}\n" else: command = "mazepa.run_worker_manager" num_procs_line = f"num_procs: {num_procs}\n" diff --git a/zetta_utils/run/gc_slack.py b/zetta_utils/run/gc_slack.py index 515fceb7..674453e7 100644 --- a/zetta_utils/run/gc_slack.py +++ b/zetta_utils/run/gc_slack.py @@ -22,8 +22,8 @@ def post_message(msg: str, priority=True): slack_client.chat_delete( channel=os.environ["SLACK_CHANNEL"], ts=RUN_DB["gc_last_msg"] ) - RUN_DB["gc_last_msg"] = response["ts"] except (KeyError, SlackApiError): ... + RUN_DB["gc_last_msg"] = response["ts"] except SlackApiError as err: logger.warning(err.response["error"])