Airflow print context

echo_context.py

from datetime import datetime, timedelta

from airflow import DAG
from airflow.operators.dummy_operator import DummyOperator
from airflow.operators.python_operator import PythonOperator

default_args = {
    "depends_on_past": False,
    "start_date": datetime(2019, 8, 1),
}


def f1(tzinfo: datetime.tzinfo = None, **context):
    for key in context:
        print((key, context[key]))


with DAG(
    "echo_context", catchup=False, default_args=default_args, schedule_interval="@daily"
) as dag:

    t1 = PythonOperator(task_id="t1", provide_context=True, python_callable=f1, dag=dag)

    t2 = DummyOperator(task_id="t2", dag=dag)