airflow.executors.dask_executor

Module Contents

class airflow.executors.dask_executor.DaskExecutor(cluster_address=None)

Bases: airflow.executors.base_executor.BaseExecutor

DaskExecutor submits tasks to a Dask Distributed cluster.

start(self)

execute_async(self, key, command, queue=None, executor_config=None)

_process_future(self, future)

sync(self)

end(self)

terminate(self)