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.

start(self)[source]
execute_async(self, key: TaskInstanceKey, command: CommandType, queue: Optional[str] = None, executor_config: Optional[Any] = None)[source]
_process_future(self, future: Future)[source]
sync(self)[source]
end(self)[source]
terminate(self)[source]

Was this entry helpful?