airflow.providers.celery.executors.default_celery

Default celery configuration.

Attributes

log

DEFAULT_CELERY_CONFIG

Functions

get_default_celery_config(team_conf)

Build Celery configuration using team-aware config.

Module Contents

airflow.providers.celery.executors.default_celery.log[source]
airflow.providers.celery.executors.default_celery.get_default_celery_config(team_conf)[source]

Build Celery configuration using team-aware config.

For Airflow versions < 3.2 that don’t support multi-team configuration, falls back to using the global conf object.

Parameters:

team_conf – ExecutorConf instance with team-specific configuration, or conf object

Returns:

Dictionary with Celery configuration

Return type:

dict[str, Any]

airflow.providers.celery.executors.default_celery.DEFAULT_CELERY_CONFIG[source]

Was this entry helpful?