airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1308] Disable nanny usage for Dask
Date Thu, 15 Jun 2017 13:44:24 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 0f55477cc -> 108267118


[AIRFLOW-1308] Disable nanny usage for Dask

Nanny is deprecated and results in build errors.

Closes #2366 from bolkedebruin/fix_dask


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/10826711
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/10826711
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/10826711

Branch: refs/heads/master
Commit: 10826711846f06476d343b150412105489096179
Parents: 0f55477
Author: Bolke de Bruin <bolke@xs4all.nl>
Authored: Thu Jun 15 09:44:16 2017 -0400
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Thu Jun 15 09:44:16 2017 -0400

----------------------------------------------------------------------
 tests/executors/dask_executor.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/10826711/tests/executors/dask_executor.py
----------------------------------------------------------------------
diff --git a/tests/executors/dask_executor.py b/tests/executors/dask_executor.py
index 51a57f2..f66a272 100644
--- a/tests/executors/dask_executor.py
+++ b/tests/executors/dask_executor.py
@@ -44,7 +44,7 @@ class DaskExecutorTest(unittest.TestCase):
 
     @unittest.skipIf(SKIP_DASK, 'Dask unsupported by this configuration')
     def test_dask_executor_functions(self):
-        cluster = LocalCluster(nanny=False)
+        cluster = LocalCluster()
 
         executor = DaskExecutor(cluster_address=cluster.scheduler_address)
 
@@ -86,7 +86,7 @@ class DaskExecutorTest(unittest.TestCase):
         """
         Test that DaskExecutor can be used to backfill example dags
         """
-        cluster = LocalCluster(nanny=False)
+        cluster = LocalCluster()
 
         dags = [
             dag for dag in self.dagbag.dags.values()


Mime
View raw message