# Safe pull – exclusive to 'generate_data' value = ti.xcom_pull(task_ids='generate_data', key='records')
If exclusive XCom access is critical for correctness, consider: airflow xcom exclusive
dag = xcom_exclusive_pipeline()
Sign in to your account
Remember me