Skip to content

Commit 73de714

Browse files
committed
fix: translate core and memory values
1 parent 8293b8a commit 73de714

1 file changed

Lines changed: 4 additions & 6 deletions

File tree

wfcommons/wfbench/translator/nextflow.py

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -191,12 +191,10 @@ def _add_abstract_task_definition(self, abstract_task_name: str, physical_tasks:
191191
: type physical_tasks: List[Task]
192192
"""
193193

194-
cores_values = [task.cores for task in physical_tasks if task.cores]
195-
cores = max(cores_values) if cores_values else None
196-
cores = int(cores) + 1 if cores else None
197-
memory_values = [task.memory for task in physical_tasks if task.memory]
198-
memory = max(memory_values) if memory_values else None
199-
memory *= 1.05 if memory else None
194+
cores_values = [task.cores for task in physical_tasks]
195+
cores = int(max(cores_values)) + 1
196+
memory_values = [task.memory for task in physical_tasks]
197+
memory = max(memory_values) * 1.05
200198

201199
# creating the command for the abstract task using the first physical task as a template
202200
example_task = physical_tasks[0]

0 commit comments

Comments
 (0)