In Apache Airflow, XCom (short for "cross-communication") is the primary mechanism for tasks to share small pieces of data within a DAG run. Unlike global Variables, which are designed for static configuration, XComs are tied to specific task instances and the lifecycle of a single execution. Core Functionality: Push & Pull
GoogleCloudStorageDownloadOperator: This operator features a strict mutual exclusivity between store_to_xcom_key and writing to a local file. You can either return the file content via XCom or save it to a filename, but not both. airflow xcom exclusive
t1 >> t2 >> t3
Exclusive XCom access refers to patterns and configurations where a single task (or a well-defined group) has exclusive write or read rights to a specific XCom key. This prevents race conditions, improves determinism, and enhances security. In Apache Airflow, XCom (short for "cross-communication") is
In Apache Airflow, XCom (short for "cross-communication") is the primary mechanism for tasks to share small pieces of data within a DAG run. Unlike global Variables, which are designed for static configuration, XComs are tied to specific task instances and the lifecycle of a single execution. Core Functionality: Push & Pull
GoogleCloudStorageDownloadOperator: This operator features a strict mutual exclusivity between store_to_xcom_key and writing to a local file. You can either return the file content via XCom or save it to a filename, but not both.
t1 >> t2 >> t3
Exclusive XCom access refers to patterns and configurations where a single task (or a well-defined group) has exclusive write or read rights to a specific XCom key. This prevents race conditions, improves determinism, and enhances security.