Skip to content
Snippets Groups Projects
Commit 2b4954cd authored by Nils-Arne Dreier's avatar Nils-Arne Dreier Committed by Siddhant Tibrewal
Browse files

fix: distribute work

parent b28ef56b
No related branches found
No related tags found
No related merge requests found
......@@ -118,7 +118,7 @@ def distribute_work(grouped_data_vars, size):
cell_chunk_size = variables[0].chunks[-1]
ncells = variables[0].shape[-1]
nchunks = ceil(ncells / cell_chunk_size)
if nchunks > nranks:
if nchunks < nranks:
logger.warning(
f"Not enough chunks to distribute work in group {group}."
" Consider using fewer processes of split up the group."
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment