Skip to content

Commit 0d3bf16

Browse files
committed
Snakemake log parser fix
1 parent f511ab0 commit 0d3bf16

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

wfcommons/wfinstances/logs/snakemake.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,16 @@ def build_workflow(self, workflow_name: Optional[str] = None) -> Workflow:
107107
# Parse the sqlite db for to identify tasks
108108
self._create_tasks()
109109

110+
# Set the workflow's makespan
111+
workflow_start_time = math.inf
112+
workflow_end_time = 0
113+
for task in self.workflow.tasks.values():
114+
task_start_time = datetime.fromisoformat(task.start_time).timestamp()
115+
task_end_time = task_start_time + task.runtime
116+
workflow_start_time = min(task_start_time, workflow_start_time)
117+
workflow_end_time = max(task_end_time, workflow_end_time)
118+
self.workflow.makespan = workflow_end_time - workflow_start_time
119+
110120
return self.workflow
111121

112122
def _build_task_map(self):

0 commit comments

Comments
 (0)