diff --git a/ci/travis/ci.sh b/ci/travis/ci.sh index 8ded407e9..2aa89dedb 100755 --- a/ci/travis/ci.sh +++ b/ci/travis/ci.sh @@ -122,6 +122,7 @@ test_core() { args+=( -//:redis_gcs_client_test -//:core_worker_test + -//:event_test -//:gcs_pub_sub_test -//:gcs_server_test -//:gcs_server_rpc_test @@ -143,7 +144,8 @@ test_python() { -python/ray/tests:test_advanced_3 # test_invalid_unicode_in_worker_log() fails on Windows -python/ray/tests:test_autoscaler_aws -python/ray/tests:test_component_failures - -python/ray/tests:test_cython + -python/ray/tests:test_basic_2 # hangs on shared cluster tests + -python/ray/tests:test_cli -python/ray/tests:test_failure -python/ray/tests:test_global_gc -python/ray/tests:test_job diff --git a/python/ray/tests/test_autoscaler.py b/python/ray/tests/test_autoscaler.py index f09fe0702..2516795c8 100644 --- a/python/ray/tests/test_autoscaler.py +++ b/python/ray/tests/test_autoscaler.py @@ -7,6 +7,7 @@ import time import unittest import yaml import copy +import sys from jsonschema.exceptions import ValidationError import ray @@ -400,6 +401,7 @@ class AutoscalingTest(unittest.TestCase): except ValidationError: self.fail("Default config did not pass validation test!") + @unittest.skipIf(sys.platform == "win32", "Failing on Windows.") def testGetOrCreateHeadNode(self): config_path = self.write_config(SMALL_CLUSTER) self.provider = MockProvider() @@ -1225,6 +1227,7 @@ class AutoscalingTest(unittest.TestCase): runner.assert_has_call("172.0.0.{}".format(i), "setup_cmd") runner.assert_has_call("172.0.0.{}".format(i), "start_ray_worker") + @unittest.skipIf(sys.platform == "win32", "Failing on Windows.") def testContinuousFileMounts(self): file_mount_dir = tempfile.mkdtemp() diff --git a/python/ray/tests/test_basic.py b/python/ray/tests/test_basic.py index d59be1b33..72cb90c42 100644 --- a/python/ray/tests/test_basic.py +++ b/python/ray/tests/test_basic.py @@ -308,6 +308,7 @@ def test_put_get(shutdown_only): assert value_before == value_after +@pytest.mark.skipif(sys.platform != "linux", reason="Failing on Windows") def test_wait_timing(shutdown_only): ray.init(num_cpus=2) diff --git a/python/ray/tests/test_command_runner.py b/python/ray/tests/test_command_runner.py index 7944c792b..4c0943475 100644 --- a/python/ray/tests/test_command_runner.py +++ b/python/ray/tests/test_command_runner.py @@ -1,6 +1,8 @@ import logging import pytest +import sys from unittest.mock import patch + from ray.tests.test_autoscaler import MockProvider, MockProcessRunner from ray.autoscaler._private.command_runner import CommandRunnerInterface, \ SSHCommandRunner, _with_environment_variables, DockerCommandRunner, \ @@ -57,6 +59,7 @@ def test_command_runner_interface_abstraction_violation(): assert allowed_public_interface_functions == subclass_public_functions +@pytest.mark.skipif(sys.platform == "win32", reason="Failing on Windows.") def test_ssh_command_runner(): process_runner = MockProcessRunner() provider = MockProvider() @@ -169,6 +172,7 @@ def test_kubernetes_command_runner(): assert pytest_wrapped_e.value.code == 1 +@pytest.mark.skipif(sys.platform == "win32", reason="Failing on Windows.") def test_docker_command_runner(): process_runner = MockProcessRunner() provider = MockProvider() @@ -217,6 +221,7 @@ def test_docker_command_runner(): process_runner.assert_has_call("1.2.3.4", exact=expected) +@pytest.mark.skipif(sys.platform == "win32", reason="Failing on Windows.") def test_docker_rsync(): process_runner = MockProcessRunner() provider = MockProvider()