Book Road Test
Facebook Instagram

Explain how to (e.g., using S3 for larger data).

If a task returns a value (specifically in PythonOperator), Airflow automatically pushes that value to XCom with the key return_value . This is the most common and cleanest method.

with DAG('xcom_example', start_date=datetime(2023, 1, 1), schedule_interval=None) as dag:

def task_b(**context): user_id = context["task_instance"].xcom_pull(task_ids="task_a", key="return_value")

bash_task = BashOperator( task_id='bash_task', bash_command='echo "Received ID: ti.xcom_pull(task_ids="extract_task") "', )

Airflow - Xcoms

Explain how to (e.g., using S3 for larger data).

If a task returns a value (specifically in PythonOperator), Airflow automatically pushes that value to XCom with the key return_value . This is the most common and cleanest method. airflow xcoms

with DAG('xcom_example', start_date=datetime(2023, 1, 1), schedule_interval=None) as dag: Explain how to (e

def task_b(**context): user_id = context["task_instance"].xcom_pull(task_ids="task_a", key="return_value") Explain how to (e.g.

bash_task = BashOperator( task_id='bash_task', bash_command='echo "Received ID: ti.xcom_pull(task_ids="extract_task") "', )