from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash_operator import BashOperator
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
When we talk about Airflow XCom being "exclusive," we're referring to the fact that XCom is only accessible to tasks within the same DAG. This means that tasks in one DAG cannot access XCom values from another DAG. from datetime import datetime, timedelta from airflow import
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. When we talk about Airflow XCom being "exclusive,"