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 <[email protected]> Authored: Thu Jun 15 09:44:16 2017 -0400 Committer: Bolke de Bruin <[email protected]> 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()
