Skip to content

Instantly share code, notes, and snippets.

@jerowe

jerowe/icecream_sundae_gather_dag_def.py

Last active March 21, 2019 16:41
Show Gist options
  • Save jerowe/f625d23c3826585fe2912568e9a3092f to your computer and use it in GitHub Desktop.
Save jerowe/f625d23c3826585fe2912568e9a3092f to your computer and use it in GitHub Desktop.
Download ZIP
Ice Cream Sundae Gather DAG Def with Airflow
Raw
icecream_sundae_gather_dag_def.py
from airflow import DAG
from icecream_sunday_dag_def import default_args
from icecream_sundae_linear_dag_def import generate_choose_cone_op, generate_choose_toppings_op, \
generate_choose_icecream_flavor_op, generate_make_icecream_sundae_op
icecream_sundae_gather_dag = DAG('ice_cream_sundae_gather_dag', default_args=default_args, schedule_interval=None)
choose_cone_op = generate_choose_cone_op(icecream_sundae_gather_dag, 1)
choose_icecream_flavor_op = generate_choose_icecream_flavor_op(icecream_sundae_gather_dag, 1)
choose_toppings_op = generate_choose_toppings_op(icecream_sundae_gather_dag, 1)
make_icecream_sundae_op = generate_make_icecream_sundae_op(icecream_sundae_gather_dag, 1)
make_icecream_sundae_op.set_upstream([choose_cone_op, choose_icecream_flavor_op, choose_toppings_op])
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment