Implemented AtLocation field, tested with input_spec

nipype · djarecka · Nov 27, 2022 · Nov 2, 2022 · Nov 2, 2022 · Nov 2, 2022
commit d0770b41ff7ef4be009e4f116e7d45c073dd2015
diff --git a/pydra/engine/audit.py b/pydra/engine/audit.py
@@ -172,9 +172,6 @@ def audit_check(self, flag):
     def audit_task(self, task):
         import subprocess as sp
 
-        args_list = [item for item in task.inputs.args if os.path.isfile(item)]
-        at_location = args_list[0]
-
         label = task.name
         entity_label = type(label)
 
@@ -184,12 +181,12 @@ def audit_task(self, task):
         else:
             command = None
 
-        # if hasattr(task.inputs, "in_file"):
-        #     input_file = task.in_file
-        #     at_location = os.path.abspath(input_file)
-        # else:
-        #     at_location = None
-        #     input_file = None
+        if hasattr(task.inputs, "in_file"):
+            input_file = task.inputs.in_file
+            at_location = os.path.abspath(input_file)
+        else:
+            at_location = None
+            input_file = None
 
         # Next question for Dorota...Should we check if
         # an output is generated by the task, and if so,
@@ -227,9 +224,9 @@ def audit_task(self, task):
             "@id": self.aid,
             "Label": print(entity_label),
             "AtLocation": at_location,
-            "GeneratedBy": "test",
+            "GeneratedBy": "test", # if not part of workflow, this will be none
             "Type": "Task",
-            "digest": "checksum",
+            "digest": "checksum" # hash value under helpers.py
         }
 
         # new code to be added here for i/o tracking - WIP