Skip to content

Commit b22bf1e

Browse files
committed
fix: check for None
1 parent 73de714 commit b22bf1e

1 file changed

Lines changed: 10 additions & 4 deletions

File tree

wfcommons/wfbench/translator/nextflow.py

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -191,10 +191,16 @@ 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]
195-
cores = int(max(cores_values)) + 1
196-
memory_values = [task.memory for task in physical_tasks]
197-
memory = max(memory_values) * 1.05
194+
cores_values = [task.cores for task in physical_tasks if task.cores is not None]
195+
if len(cores_values) == 0:
196+
cores = None
197+
else:
198+
cores = int(max(cores_values)) + 1
199+
memory_values = [task.memory for task in physical_tasks if task.memory is not None]
200+
if len(memory_values) == 0:
201+
memory = None
202+
else:
203+
memory = max(memory_values) * 1.05
198204

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

0 commit comments

Comments
 (0)