Skip to content

Commit 7eb61e5

Browse files
committed
Simplify rechunking call
1 parent 718c9a3 commit 7eb61e5

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

sgkit/window.py

+2-4
Original file line numberDiff line numberDiff line change
@@ -103,9 +103,7 @@ def window_statistic(
103103
if depth > values.chunks[0][-1]:
104104
chunk0 = values.chunks[0]
105105
new_chunk0 = tuple(list(chunk0[:-2]) + [chunk0[-2] + chunk0[-1]])
106-
# None means don't rechunk along that axis
107-
new_chunks = tuple(list([new_chunk0] + ([None] * (len(chunk0) - 1)))) # type: ignore
108-
values = values.rechunk(new_chunks)
106+
values = values.rechunk({0: new_chunk0})
109107

110108
chunks = values.chunks[0]
111109

@@ -141,7 +139,7 @@ def blockwise_moving_stat(x: ArrayLike, block_info: Any = None) -> ArrayLike:
141139
# depth is 0 except in first axis
142140
depth = tuple([depth] + ([0] * (values.ndim - 1)))
143141
# new chunks are same except in first axis
144-
new_chunks = tuple([tuple(windows_per_chunk)] + list(values.chunks[1:]))
142+
new_chunks = tuple([tuple(windows_per_chunk)] + list(values.chunks[1:])) # type: ignore
145143
return values.map_overlap(
146144
blockwise_moving_stat,
147145
dtype=dtype,

0 commit comments

Comments
 (0)