Skip to content

Commit

Permalink
test: Fix teardown
Browse files Browse the repository at this point in the history
Signed-off-by: Weixin Deng <weixin@cs.washington.edu>
  • Loading branch information
dengwxn committed Sep 25, 2024
1 parent d2fbe4d commit b6a2c9e
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 @@ -1807,6 +1807,8 @@ def test_torch_tensor_nccl_all_reduce_scheduling(ray_start_regular):
assert torch.equal(result[1], expected_tensor_value)
assert result[2] == (value, shape, dtype)

compiled_dag.teardown()


@pytest.mark.parametrize("ray_start_regular", [{"num_cpus": 4}], indirect=True)
def test_torch_tensor_nccl_all_reduce_scheduling_one_ready_group(ray_start_regular):
Expand Down Expand Up @@ -1848,6 +1850,8 @@ def test_torch_tensor_nccl_all_reduce_scheduling_one_ready_group(ray_start_regul
result = ray.get(ref)
assert result == [(value * 2, shape, dtype) for _ in workers]

compiled_dag.teardown()


if __name__ == "__main__":
if os.environ.get("PARALLEL_CI"):
Expand Down

0 comments on commit b6a2c9e

Please sign in to comment.