Skip to content

Commit

Permalink
bug fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
jan-janssen committed May 7, 2024
1 parent ccd526a commit 6172507
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 1 deletion.
2 changes: 2 additions & 0 deletions pympipool/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -143,6 +143,7 @@ def __new__(
"""
if not disable_dependencies:
return ExecutorWithDependencies(
max_workers=max_workers,
max_cores=max_cores,
cores_per_worker=cores_per_worker,
threads_per_core=threads_per_core,
Expand All @@ -160,6 +161,7 @@ def __new__(
else:
_check_refresh_rate(refresh_rate=refresh_rate)
return create_executor(
max_workers=max_workers,
max_cores=max_cores,
cores_per_worker=cores_per_worker,
threads_per_core=threads_per_core,
Expand Down
2 changes: 1 addition & 1 deletion pympipool/shared/inputcheck.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,5 +83,5 @@ def check_init_function(block_allocation, init_function):
def validate_number_of_cores(max_cores, max_workers):
# only overwrite max_cores when it is set to 1
if max_workers != 1 and max_cores == 1:
max_cores = max_workers
return max_workers
return max_cores

0 comments on commit 6172507

Please sign in to comment.