Skip to content

Commit

Permalink
Update pipeline.py (#106)
Browse files Browse the repository at this point in the history
  • Loading branch information
rabernat authored Nov 29, 2021
1 parent 5ef2c3a commit 0a0d1eb
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion rechunker/pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,6 @@ def _copy_chunk(chunk_key):
# calling np.asarray here allows the source to be a dask array
# TODO: could we asyncify this to operate in a streaming fashion
# make sure this is not happening inside a dask scheduler
print(f"_copy_chunk({chunk_key})")
with dask.config.set(scheduler="single-threaded"):
data = np.asarray(source[chunk_key])
target[chunk_key] = data
Expand Down

0 comments on commit 0a0d1eb

Please sign in to comment.