From a153c7c0001c8e69ed7de685b0dba3236b7e53c5 Mon Sep 17 00:00:00 2001 From: Nathan Freeman Date: Mon, 6 Nov 2023 16:07:30 -0600 Subject: [PATCH] debug --- src/engine/src/contrib/tapis/executors/TapisJob.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/engine/src/contrib/tapis/executors/TapisJob.py b/src/engine/src/contrib/tapis/executors/TapisJob.py index 74e45a2a..625b627a 100644 --- a/src/engine/src/contrib/tapis/executors/TapisJob.py +++ b/src/engine/src/contrib/tapis/executors/TapisJob.py @@ -26,6 +26,7 @@ def execute(self): for parent_task_output_file in parent_task_output: # Skip all output files that do not contain the Tapis # system file reference extension + print("PARENT TASK OUTPUT FILE", parent_task_output_file) if TAPIS_SYSTEM_FILE_REF_EXTENSION not in parent_task_output_file.name: continue @@ -77,6 +78,7 @@ def execute(self): _x_tapis_user=self.ctx.args.get("tapis_pipeline_owner").value ) for file in files: + print("FILE", file) self._set_output( file.name + "." + TAPIS_SYSTEM_FILE_REF_EXTENSION, json.dumps( @@ -88,7 +90,7 @@ def execute(self): ) return self._task_result(0) - + print("JOB", job) return self._task_result(1, errors=[f"Job '{job.name}' ended with status {job.status}. Last Message: {job.lastMessage}"]) except Exception as e: