From 47939a3240b6b0fd5aa732d2d2036267ec872335 Mon Sep 17 00:00:00 2001 From: tomMoral Date: Mon, 8 Feb 2021 22:30:46 +0100 Subject: [PATCH] ENH rm low timeout for reusable executor as it is too slow on CI --- tests/_executor_mixin.py | 3 ++- tests/_test_process_executor.py | 3 ++- tests/test_reusable_executor.py | 6 ++---- 3 files changed, 6 insertions(+), 6 deletions(-) diff --git a/tests/_executor_mixin.py b/tests/_executor_mixin.py index 7f74bf8a..4d8f399f 100644 --- a/tests/_executor_mixin.py +++ b/tests/_executor_mixin.py @@ -143,7 +143,8 @@ def setup_method(self): try: self.executor = self.executor_type( max_workers=self.worker_count, context=self.context, - initializer=initializer_event, initargs=(_test_event,)) + initializer=initializer_event, initargs=(_test_event,) + ) except NotImplementedError as e: self.skipTest(str(e)) _check_executor_started(self.executor) diff --git a/tests/_test_process_executor.py b/tests/_test_process_executor.py index fb68c873..9f00e0af 100644 --- a/tests/_test_process_executor.py +++ b/tests/_test_process_executor.py @@ -416,7 +416,8 @@ def _test_recursive_kill(cls, depth): executor = cls.executor_type( max_workers=2, context=cls.context, initializer=_executor_mixin.initializer_event, - initargs=(_executor_mixin._test_event,)) + initargs=(_executor_mixin._test_event,) + ) assert executor.submit(sleep_and_return, 0, 42).result() == 42 if depth >= 2: diff --git a/tests/test_reusable_executor.py b/tests/test_reusable_executor.py index 9ac6a2a3..2c413d34 100644 --- a/tests/test_reusable_executor.py +++ b/tests/test_reusable_executor.py @@ -587,10 +587,9 @@ def _worker_rank(x): return dict(pid=os.getpid(), name=mp.current_process().name, rank=rank, world=world) - @pytest.mark.parametrize('timeout', [10, 0.01]) - def test_workers_rank_resize(self, timeout): + def test_workers_rank_resize(self): - executor = get_reusable_executor(max_workers=2, timeout=timeout) + executor = get_reusable_executor(max_workers=2) with warnings.catch_warnings(record=True): # Cause all warnings to always be triggered. @@ -609,7 +608,6 @@ def test_workers_rank_resize(self, timeout): ', '.join('{}: {}'.format(k, v) for k, v in executor._rank_mapper.items()) ) - executor.shutdown(wait=True) class TestGetReusableExecutor(ReusableExecutorMixin):