Airflow Xcom Exclusive [portable] -

@task def get_exclusive_token(): return "secret-token-123" @task def process_data(token): print(f"Using {token}") # Airflow handles the XCom exchange automatically token = get_exclusive_token() process_data(token) Use code with caution. Explicit Key Management

Since XComs live in your Airflow backend (Postgres/MySQL), pushing large objects (like full DataFrames) can crash your scheduler. Exclusive management involves: airflow xcom exclusive

Only push IDs or S3 paths rather than raw data. airflow xcom exclusive