Skip to content

Commit 20d0699

Browse files
authored
[Fix] Fix comm test (#1691)
1 parent 686f5e3 commit 20d0699

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

tests/distributed/test_comm_ops.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22
33
Run `pytest tests/distributed/test_comm_ops.py --forked`.
44
"""
5-
from multiprocessing import Process
5+
from multiprocessing import Process, set_start_method
66

77
import pytest
88
import torch
@@ -70,6 +70,7 @@ def all_gather_test_worker(tensor_parallel_size: int, rank: int,
7070
@pytest.mark.parametrize("test_target",
7171
[all_reduce_test_worker, all_gather_test_worker])
7272
def test_multi_process_tensor_parallel(tensor_parallel_size, test_target):
73+
set_start_method("spawn", force=True)
7374
distributed_init_port = get_open_port()
7475
processes = []
7576
for rank in range(tensor_parallel_size):

0 commit comments

Comments
 (0)