Airflow Xcom Exclusive -

task1 >> task2 In this example, task1 pushes a greeting message to XCom using xcom_push_key . task2 then pulls that message from XCom using xcom_pull and prints it.

In Airflow, XCom is implemented as a key-value store that's accessible to all tasks in a DAG. When a task wants to share data with other tasks, it can use the xcom_push method to store a value in XCom. Other tasks can then use the xcom_pull method to retrieve that value. airflow xcom exclusive

dag = DAG( 'xcom_example', default_args=default_args, schedule_interval=timedelta(days=1), ) task1 >> task2 In this example, task1 pushes

default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start_date': datetime(2023, 3, 20), 'retries': 1, 'retry_delay': timedelta(minutes=5), } task2 In this example