`airflow.executors.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.

start(self)[source]¶

execute_async(self, key, command, queue=None, executor_config=None)[source]¶

_process_future(self, future)[source]¶

sync(self)[source]¶

end(self)[source]¶

terminate(self)[source]¶

Was this entry helpful?