`airflow.executors.executor_loader`¶

All executors.

Module Contents¶

Classes¶

`ConnectorSource`	Enum of supported executor import sources.
`ExecutorLoader`	Keeps constants for all the currently available executors.

Attributes¶

`log`
`UNPICKLEABLE_EXECUTORS`

airflow.executors.executor_loader.log[source]¶

class airflow.executors.executor_loader.ConnectorSource[source]¶

Bases: enum.Enum

Enum of supported executor import sources.

CORE = 'core'[source]¶

PLUGIN = 'plugin'[source]¶

CUSTOM_PATH = 'custom path'[source]¶

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

Keeps constants for all the currently available executors.

executors[source]¶

classmethod get_default_executor()[source]¶

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

classmethod load_executor(executor_name)[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
Return type: airflow.executors.base_executor.BaseExecutor

classmethod import_executor_cls(executor_name)[source]¶

Imports the executor class.

Supports the same formats as ExecutorLoader.load_executor.

Returns: executor class via executor_name and executor import source
Return type: tuple[type[airflow.executors.base_executor.BaseExecutor], ConnectorSource]

airflow.executors.executor_loader.UNPICKLEABLE_EXECUTORS = ()[source]¶

airflow.executors.executor_loader¶

Module Contents¶

Classes¶

Attributes¶

`airflow.executors.executor_loader`¶