@task def extract() -> dict: return "user_id": 123, "name": "Alice" # pushed automatically
@task def process(user_data: dict) -> str: return f"Processed user user_data['name']"
from airflow.operators.python import PythonOperator def push_function(**context): context['ti'].xcom_push(key='user_id', value=123)