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 <[email protected]>
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(
