Airflow Xcom Exclusive Page

: While primarily used within one DAG, xcom_pull can be configured with a different dag_id to retrieve values from an entirely separate workflow, provided you have the correct execution date or use include_prior_dates=True . Critical Limitations XComs — Airflow 3.2.1 Documentation

check_value = ShortCircuitOperator( task_id="check_score", python_callable=lambda **context: context["ti"].xcom_pull(task_ids="model", key="score") > 0.8, ) airflow xcom exclusive

from airflow.decorators import dag, task from datetime import datetime : While primarily used within one DAG, xcom_pull

This is the most critical constraint. Because XComs live in the metadata database, they are . ) from airflow.decorators import dag