From 7eef85c4e2578001cbaac67bca44e05f5d777167 Mon Sep 17 00:00:00 2001 From: Thiago Monteiro Date: Tue, 5 Mar 2024 15:17:52 +0000 Subject: [PATCH] rm unnecessary bits --- workflow_funcs/workflow_setup.py | 20 -------------------- 1 file changed, 20 deletions(-) diff --git a/workflow_funcs/workflow_setup.py b/workflow_funcs/workflow_setup.py index d6eafdf..4f78aa8 100644 --- a/workflow_funcs/workflow_setup.py +++ b/workflow_funcs/workflow_setup.py @@ -98,7 +98,6 @@ def setup_workflow(client, templateWkf, gsWkf, params): workflow.name = "{}_{}".format(templateWkf.name, datetime.now().strftime("%Y%m%d_%H%M%S")) workflow.id = '' - workflow = check_install_operators( workflow, client, params) if params["update_operator"] == True: util.msg("Checking for updated operator versions", params["verbose"]) @@ -137,25 +136,6 @@ def setup_workflow(client, templateWkf, gsWkf, params): return workflow -def check_install_operators( workflow, client, params): - stepFound = False - for stp in workflow.steps: - if hasattr(stp.model, "operatorSettings"): - opRef = stp.model.operatorSettings.operatorRef - - util.msg("Checking operator {} install for step '{}':".format(opRef.name, stp.name), verbose=params["verbose"]) - - operator = get_installed_operator(client, opRef.name, \ - opRef.url, opRef.version, params, verbose=params["verbose"]) - - stp.model.operatorSettings.operatorRef.operatorId = operator.id - stp.model.operatorSettings.operatorRef.name = operator.name - stp.model.operatorSettings.operatorRef.url = operator.url - stp.model.operatorSettings.operatorRef.version = operator.version - - #TODO print message if operator name was not found - - return workflow