`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?