@task def consumer_1(data): # data is automatically pulled only to this task print(data)
If you want, I can:
, you simply return a value from a Python function, and Airflow manages the XCom lifecycle for you. XComs — Airflow 3.2.0 Documentation airflow xcom exclusive