Skip to content

Commit

Permalink
remove check of execSystemExecDir
Browse files Browse the repository at this point in the history
  • Loading branch information
nathandf committed Nov 6, 2023
1 parent b1ca242 commit 1e069f0
Showing 1 changed file with 1 addition and 15 deletions.
16 changes: 1 addition & 15 deletions src/engine/src/contrib/tapis/executors/TapisJob.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,20 +17,6 @@ def execute(self):

# Recursively convert nested simple namespace objects to dict
job_def = ReqSubmitJob(**json.loads(json.dumps(self.task.tapis_job_def, default=lambda s: dict(s))))

exec_system_input_dir = job_def.execSystemInputDir
if exec_system_input_dir == None:
app = service_client.apps.getApp(
appId=job_def.appId,
appVersion=job_def.appVersion,
_x_tapis_tenant=self.ctx.args.get("tapis_tenant_id").value,
_x_tapis_user=self.ctx.args.get("tapis_pipeline_owner").value
)
exec_system_input_dir = app.jobAttributes.execSystemInputDir

if exec_system_input_dir == None:
exec_system_input_dir = "*"
# raise Exception("Exec system input dir must be specified in either the App or the Job definition")

# Add TapisSystemFiles from previous task output as fileInput/Arrays to the job definition
file_input_arrays = []
Expand All @@ -53,7 +39,7 @@ def execute(self):
"name": f"owe-implicit-input-{parent_task.id}",
"description": f"These files were generated as a result of an Open Workflow Engine task execution for the pipeline '{self.ctx.pipeline.id}' and task '{parent_task.id}'.",
"sourceUrls": source_urls,
"targetDir": exec_system_input_dir,
"targetDir": "*",
"notes": {}
})

Expand Down

0 comments on commit 1e069f0

Please sign in to comment.