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(