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?