debug

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: