You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by el...@apache.org on 2022/01/23 21:49:41 UTC
[airflow] branch main updated: Insrease timeout for occasionally failing Dask test (#21051)
This is an automated email from the ASF dual-hosted git repository.
eladkal 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 795a6bb Insrease timeout for occasionally failing Dask test (#21051)
795a6bb is described below
commit 795a6bb066c4f680dcc324758366d59c58eec572
Author: Jarek Potiuk <ja...@potiuk.com>
AuthorDate: Sun Jan 23 22:49:03 2022 +0100
Insrease timeout for occasionally failing Dask test (#21051)
---
tests/executors/test_dask_executor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tests/executors/test_dask_executor.py b/tests/executors/test_dask_executor.py
index c35f9b2..7278552 100644
--- a/tests/executors/test_dask_executor.py
+++ b/tests/executors/test_dask_executor.py
@@ -175,7 +175,7 @@ class TestDaskExecutorQueue(unittest.TestCase):
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=120)
while not success_future.done():
if timezone.utcnow() > timeout:
raise ValueError(