airflow.executors.dask_executor
¶
DaskExecutor
See also
For more information on how the DaskExecutor works, take a look at the guide: Dask Executor
Module Contents¶
-
class
airflow.executors.dask_executor.
DaskExecutor
(cluster_address=None)[source]¶ Bases:
airflow.executors.base_executor.BaseExecutor
DaskExecutor submits tasks to a Dask Distributed cluster.