Skip to content

Commit 4fbc5c9

Browse files
committed
Minor fix in nccl_asarray
1 parent 175a396 commit 4fbc5c9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pylops_mpi/utils/_nccl.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -286,7 +286,7 @@ def nccl_asarray(nccl_comm, local_array, local_shapes, axis) -> cp.ndarray:
286286

287287
send_buf, recv_buf = _prepare_allgather_inputs_nccl(local_array, local_shapes, engine="cupy")
288288
nccl_allgather(nccl_comm, send_buf, recv_buf)
289-
chunks = _unroll_allgather_recv(recv_buf, local_shapes, send_buf.shape, engine="cupy")
289+
chunks = _unroll_allgather_recv(recv_buf, send_buf.shape, local_shapes)
290290

291291
# combine back to single global array
292292
return cp.concatenate(chunks, axis=axis)

0 commit comments

Comments
 (0)