Skip to content

Commit 785f7d3

Browse files
committed
Ensure Task ID uniqueness in RO-Crate parser
1 parent ca9f0cb commit 785f7d3

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

wfcommons/wfinstances/logs/ro_crate.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -159,17 +159,17 @@ def _create_tasks(self, create_actions, main_workflow_id):
159159

160160

161161
task = Task(name=create_action['name'],
162-
task_id=create_action['name'],
163-
# task_id=create_action['name'] + "_" + create_action['@id'],
162+
# task_id=create_action['name'],
163+
task_id=create_action['name'] + "_" + create_action['@id'],
164164
task_type=TaskType.COMPUTE,
165165
runtime=self._time_diff(create_action['startTime'], create_action['endTime']),
166166
executed_at=create_action['startTime'],
167167
input_files=self._get_file_objects(input_files),
168168
output_files=self._get_file_objects(output_files),
169169
logger=self.logger)
170170
self.workflow.add_task(task)
171-
self.task_id_name_map[create_action['@id']] = create_action['name']
172-
# self.task_id_name_map[create_action['@id']] = create_action['name'] + "_" + create_action['@id']
171+
# self.task_id_name_map[create_action['@id']] = create_action['name']
172+
self.task_id_name_map[create_action['@id']] = create_action['name'] + "_" + create_action['@id']
173173

174174
# For each file, track which task(s) it is in/output for
175175
for infile in input_files:

0 commit comments

Comments
 (0)