For medium blog post: Airflow Dynamic DAGs - Python Globals

broken_dynamic_dag.py

def create_dag(symbol):
    with DAG(
        "email_{}_price".format(symbol.lower()),
        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
        )
        return dag


for symbol in ("BTC", "ETH", "LTC", "XLM"):
    dag = create_dag(symbol=symbol)