Skip to content

Commit 3207ad2

Browse files
committed
updating TaskVine parser to support version 2
1 parent c7f1d04 commit 3207ad2

1 file changed

Lines changed: 4 additions & 5 deletions

File tree

wfcommons/wfinstances/logs/taskvine.py

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -227,14 +227,13 @@ def _construct_task_input_output_files(self) -> None:
227227
self.task_output_files[task_id] = []
228228

229229
with open(self.taskgraph_file) as f:
230-
for line in f:
231-
if line.startswith("#"):
232-
continue
233-
230+
for line in f:
234231
if line.startswith("TASK"):
235232
# TASK T23 "__vine_env_task-rnd-twtxpejwzsyiebf/bin/run_in_env" INPUTS task-rnd-twtxpejwzsyiebf file-meta-d7504c061a7afd9401c612b4ac7d6be6 file-meta-baab4e4516c4d93a8fcdcbba1a680af7 file-meta-693cb61fedd032b4ddec444b8cce6c89 file-rnd-fnrudlxsaqmlpqq OUTPUTS file-rnd-pdtdqayfmmxyxyp
236233
parts = line.split()
237-
task_key = parts[1] # T23
234+
task_key = parts[1]
235+
if not task_key.startswith("T"):
236+
continue
238237
task_id = int(task_key[1:]) # Remove the T
239238
if task_id not in self.known_task_ids:
240239
continue

0 commit comments

Comments
 (0)