@@ -172,9 +172,6 @@ def audit_check(self, flag):
172
172
def audit_task (self , task ):
173
173
import subprocess as sp
174
174
175
- args_list = [item for item in task .inputs .args if os .path .isfile (item )]
176
- at_location = args_list [0 ]
177
-
178
175
label = task .name
179
176
entity_label = type (label )
180
177
@@ -184,12 +181,12 @@ def audit_task(self, task):
184
181
else :
185
182
command = None
186
183
187
- # if hasattr(task.inputs, "in_file"):
188
- # input_file = task.in_file
189
- # at_location = os.path.abspath(input_file)
190
- # else:
191
- # at_location = None
192
- # input_file = None
184
+ if hasattr (task .inputs , "in_file" ):
185
+ input_file = task . inputs .in_file
186
+ at_location = os .path .abspath (input_file )
187
+ else :
188
+ at_location = None
189
+ input_file = None
193
190
194
191
# Next question for Dorota...Should we check if
195
192
# an output is generated by the task, and if so,
@@ -227,9 +224,9 @@ def audit_task(self, task):
227
224
"@id" : self .aid ,
228
225
"Label" : print (entity_label ),
229
226
"AtLocation" : at_location ,
230
- "GeneratedBy" : "test" ,
227
+ "GeneratedBy" : "test" , # if not part of workflow, this will be none
231
228
"Type" : "Task" ,
232
- "digest" : "checksum" ,
229
+ "digest" : "checksum" # hash value under helpers.py
233
230
}
234
231
235
232
# new code to be added here for i/o tracking - WIP
0 commit comments