airflow.executors.executor_loader

All executors.

Module Contents

airflow.executors.executor_loader.log[source]
class airflow.executors.executor_loader.ExecutorLoader[source]

Keeps constants for all the currently available executors.

_default_executor :Optional[BaseExecutor][source]
executors[source]
classmethod get_default_executor(cls)[source]

Creates a new instance of the configured executor if none exists and returns it

classmethod load_executor(cls, executor_name: str)[source]

Loads the executor.

This supports the following formats: * by executor name for core executor * by {plugin_name}.{class_name} for executor from plugins * by import path.

Returns

an instance of executor class via executor_name

classmethod __load_celery_kubernetes_executor(cls)[source]
Returns

an instance of CeleryKubernetesExecutor

airflow.executors.executor_loader.UNPICKLEABLE_EXECUTORS[source]

Was this entry helpful?