Skip to content

Commit

Permalink
rm unnecessary bits
Browse files Browse the repository at this point in the history
  • Loading branch information
tsmonteiro committed Mar 5, 2024
1 parent 7d2bd7f commit 7eef85c
Showing 1 changed file with 0 additions and 20 deletions.
20 changes: 0 additions & 20 deletions workflow_funcs/workflow_setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -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"])
Expand Down Expand Up @@ -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



Expand Down

0 comments on commit 7eef85c

Please sign in to comment.