Skip to content

Commit

Permalink
do get before checking for channel timeout
Browse files Browse the repository at this point in the history
Signed-off-by: dayshah <[email protected]>
  • Loading branch information
dayshah committed Jan 16, 2025
1 parent f78c82c commit bdb9b53
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions python/ray/dag/tests/experimental/test_torch_tensor_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -1125,6 +1125,10 @@ def test_torch_tensor_nccl_all_reduce_wrong_shape(ray_start_regular):
# exception, such as when the task returns torch.Tensors of the wrong
# shape or dtype. Check that we can no longer submit to the DAG.
ref = compiled_dag.execute([((20,), dtype, 1) for _ in workers])
try:
ray.get(ref)
except Exception:
pass
with pytest.raises(RayChannelError):
ref = compiled_dag.execute([((20,), dtype, 1) for _ in workers])

Expand Down

0 comments on commit bdb9b53

Please sign in to comment.