Exclusive | Airflow Xcom

from datetime import datetime, timedelta from airflow import DAG from airflow.operators.bash_operator import BashOperator

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. airflow xcom exclusive

task1 = BashOperator( task_id='task1', bash_command='echo "Hello, World!"', xcom_push_key='greeting', dag=dag, ) from datetime import datetime, timedelta from airflow import

dag = DAG( 'xcom_example', default_args=default_args, schedule_interval=timedelta(days=1), ) from datetime import datetime

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