iterate over shards instead of chunks in second branch

d-v-b · d-v-b · commit 6abd5b5f8c0b · 2025-09-01T18:21:31.000+02:00
diff --git a/src/zarr/core/array.py b/src/zarr/core/array.py
@@ -4421,7 +4421,7 @@ async def _copy_arraylike_region(chunk_coords: slice, _data: NDArrayLike) -> Non
 
             # Stream data from the source array to the new array
             await concurrent_map(
-                [(region, data) for region in result._iter_chunk_regions()],
+                [(region, data) for region in result._iter_shard_regions()],
                 _copy_arraylike_region,
                 zarr.core.config.config.get("async.concurrency"),
             )

Original file line number	Diff line number	Diff line change
`@@ -4421,7 +4421,7 @@ async def _copy_arraylike_region(chunk_coords: slice, _data: NDArrayLike) -> Non`
`4421`	`4421`
`4422`	`4422`	`# Stream data from the source array to the new array`
`4423`	`4423`	`await concurrent_map(`
`4424`		`- [(region, data) for region in result._iter_chunk_regions()],`
	`4424`	`+ [(region, data) for region in result._iter_shard_regions()],`
`4425`	`4425`	`_copy_arraylike_region,`
`4426`	`4426`	`zarr.core.config.config.get("async.concurrency"),`
`4427`	`4427`	`)`