docs-archive/1.10.3/_sources/_api/airflow/executors/dask_executor/index.rst.txt

:mod:`airflow.executors.dask_executor`
======================================

.. py:module:: airflow.executors.dask_executor







Module Contents
---------------






.. py:class:: DaskExecutor(cluster_address=None)

   Bases::class:`airflow.executors.base_executor.BaseExecutor`

   

   DaskExecutor submits tasks to a Dask Distributed cluster.


   

   

   

   .. method:: start(self)

      



   

   .. method:: execute_async(self, key, command, queue=None, executor_config=None)

      



   

   .. method:: _process_future(self, future)

      



   

   .. method:: sync(self)

      



   

   .. method:: end(self)

      



   

   .. method:: terminate(self)