Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Temporarily skip comm test cases #7015

Merged
merged 3 commits into from
Dec 13, 2021
Merged

Temporarily skip comm test cases #7015

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
7e5f55c
Temporarily skip comm test cases
liufengwei0103 Dec 13, 2021
3edb4e7
auto format by CI
oneflow-ci-bot Dec 13, 2021
e0b653f
Merge branch 'master' into temporarily_skip_comm_test_case
oneflow-ci-bot Dec 13, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 9 additions & 0 deletions python/oneflow/test/modules/test_comm_ops.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@
import torch.distributed as dist


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestAllReduce(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n2d()
Expand All @@ -49,6 +50,7 @@ def test_all_reduce_2n2d(test_case):
test_case.assertTrue(np.allclose(tensor.numpy(), np_arr * 4))


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestAllGather(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n2d()
Expand Down Expand Up @@ -77,6 +79,7 @@ def test_all_gather_1n2d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestBroadCast(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n2d()
Expand All @@ -103,6 +106,7 @@ def test_broadcast_1n2d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestScatter(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n4d()
Expand All @@ -128,6 +132,7 @@ def test_scatter_1n4d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestGather(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n4d()
Expand Down Expand Up @@ -163,6 +168,7 @@ def test_gather_1n4d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestReduce(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n2d()
Expand Down Expand Up @@ -191,6 +197,7 @@ def test_reduce_1n2d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestAllToAll(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n4d()
Expand Down Expand Up @@ -224,6 +231,7 @@ def test_all_to_all_1n4d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
class TestReduceScatter(flow.unittest.TestCase):
@flow.unittest.skip_unless_1n4d()
Expand All @@ -250,6 +258,7 @@ def test_reduce_scatter_1n4d(test_case):
dist.destroy_process_group()


@unittest.skip("comm test case has bug")
@unittest.skipIf(os.getenv("ONEFLOW_TEST_CPU_ONLY"), "only test cpu cases")
@flow.unittest.skip_unless_1n2d()
class TestDocs(flow.unittest.TestCase):
Expand Down