Xcoms [top] - Airflow

def extract_data(**kwargs): # Simulate data extraction data_id = "file_12345.csv" # This return value is automatically pushed to XCom return data_id

Would you like a concrete example of replacing large XComs with an S3 + reference pattern? airflow xcoms

– If a task has multiple return statements or uses xcom_push manually, it’s easy to lose the default return_value key. airflow xcoms