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.