Skip to content

Instantly share code, notes, and snippets.

@agalea91

agalea91/fixed_dynamic_dag.py

Last active September 17, 2020 05:52
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save agalea91/9161e0a3d973ef01b93460691799f048 to your computer and use it in GitHub Desktop.
Save agalea91/9161e0a3d973ef01b93460691799f048 to your computer and use it in GitHub Desktop.
Download ZIP
For medium blog post: Airflow Dynamic DAGs - Python Globals
Raw
fixed_dynamic_dag.py
for symbol in ("BTC", "ETH", "LTC", "XLM"):
dag = create_dag(symbol=symbol)
globals()["{}_dag".format(symbol.lower())] = dag
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment