Export dynamic environment variables available for operators to use¶
The key value pairs returned in get_airflow_context_vars
defined in
airflow_local_settings.py
are injected to default airflow context environment variables,
which are available as environment variables when running tasks. Note, both key and
value are must be string.
dag_id
, task_id
, execution_date
, dag_run_id
,
dag_owner
, dag_email
are reserved keys.
For example, in your airflow_local_settings.py
file:
def get_airflow_context_vars(context) -> dict[str, str]:
"""
:param context: The context for the task_instance of interest.
"""
# more env vars
return {"airflow_cluster": "main"}
See Configuring local settings for details on how to configure local settings.