Skip to content

Instantly share code, notes, and snippets.

@kvnkho

kvnkho/prefect_case.py

Last active May 28, 2022 05:20
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save kvnkho/043f527efcdbac23393b5b4aea169f18 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save kvnkho/043f527efcdbac23393b5b4aea169f18 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
prefect_case.py
# Prefect 1.0
with Flow("basic") as flow:
e = extract()
cond = check_condition()
with case(cond, True):
t1 = transform1(e)
with case(cond, False):
t2 = transform2(e)
t = merge(t1,t2)
l = load(t)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment