Let’s build a DAG that performs three steps:
process = PythonOperator( task_id='process_order_task', python_callable=process_order )
Think of it like a secret note passed between two students sitting on opposite sides of the classroom. One student writes the note (Push), leaves it on the teacher's desk (the Metadata Database), and the other student picks it up (Pull).