airflow.executors.executor_loader
¶
All executors.
Module Contents¶
Classes¶
Enum of supported executor import sources. |
|
Keeps constants for all the currently available executors. |
Attributes¶
- class airflow.executors.executor_loader.ConnectorSource[source]¶
Bases:
enum.Enum
Enum of supported executor import sources.
- class airflow.executors.executor_loader.ExecutorLoader[source]¶
Keeps constants for all the currently available executors.
- 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
- 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]