with DAG( "fraud_detection", xcom_exclusive_keys= "fetch_transactions": ["raw_txns"], "validate": ["valid_txns", "error_count"], "feature_engineering": ["features"], "fraud_model": ["score"], , xcom_backend="myapp.xcom.S3ExclusiveXCom", ) as dag:
@dag(start_date=datetime(2023,1,1), schedule=None, catchup=False) def xcom_exclusive_pipeline(): airflow xcom exclusive
trigger = TriggerDagRunOperator( task_id="trigger_child", trigger_dag_id="child_dag", conf="xcom_passthrough": " ti.xcom_pull(task_ids='parent_task', key='authorized_key') ", ) with DAG( "fraud_detection"
def push_exclusive(ti): ti.xcom_push(key=f"run_ti.execution_date_data", value="sensitive") xcom_exclusive_keys= "fetch_transactions": ["raw_txns"]