This is an automated email from the ASF dual-hosted git repository. potiuk pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push: new 7b8272bbcf Increase timeouts for flaky daskexecutor test (#35473) 7b8272bbcf is described below commit 7b8272bbcf2749ba8996534eddc3ac963dcba38c Author: Jarek Potiuk <ja...@potiuk.com> AuthorDate: Mon Nov 6 23:09:59 2023 +0100 Increase timeouts for flaky daskexecutor test (#35473) The recent change with splitting the DB from Non-DB tests likely increased a bit pressure on paralell-executing DB tests because they are likely often competing for resources such as DB I/O /networking with other tests running in parallel on the same machine, so the dask executor tests started to (again) timeout. Increasing the timeout might help - if not we will quarantine the tests and try to solve it differently. --- tests/providers/daskexecutor/test_dask_executor.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/tests/providers/daskexecutor/test_dask_executor.py b/tests/providers/daskexecutor/test_dask_executor.py index 8e870cc4b8..9ba55bf421 100644 --- a/tests/providers/daskexecutor/test_dask_executor.py +++ b/tests/providers/daskexecutor/test_dask_executor.py @@ -214,6 +214,7 @@ class TestDaskExecutorQueue: assert success_future.done() assert success_future.exception() is None + @pytest.mark.execution_timeout(120) def test_dask_queues_no_queue_specified(self): self.cluster = LocalCluster(resources={"queue1": 1}) executor = DaskExecutor(cluster_address=self.cluster.scheduler_address) @@ -224,7 +225,7 @@ class TestDaskExecutorQueue: success_future = next(k for k, v in executor.futures.items() if v == "success") # wait for the futures to execute, with a timeout - timeout = timezone.utcnow() + timedelta(seconds=30) + timeout = timezone.utcnow() + timedelta(seconds=100) while not success_future.done(): if timezone.utcnow() > timeout: raise ValueError(