For medium blog post: Airflow Dynamic DAGs - Python Globals

static_dag.py

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

from crypto_prices import get_price, send_email

with DAG(
    "email_bitcoin_price",
    default_args={"start_date": "2020-01-01"},
    schedule_interval="0 0 * * *",
) as dag:
    get_price_task = PythonOperator(
        task_id="get_price",
        python_callable=get_price,
        op_kwargs=dict(
            symbol="BTC",
        ),
    )
    email_price_task = PythonOperator(
        task_id="email_price",
        python_callable=email_price,
    )
    (
        get_price_task
        >> email_price_task
    )