Skip to content

Instantly share code, notes, and snippets.

@LordBastor
Created February 5, 2021 16:10
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
Save LordBastor/c88e46bba881377a2652ab1d3380a67c to your computer and use it in GitHub Desktop.
from prefect import Flow, task
@task
def extract():
return [1, 2, 3]
@task
def transform(x):
return [i * 10 for i in x]
@task
def load(y):
print("Received y: {}".format(y))
with Flow("ETL") as flow:
e = extract()
t = transform(e)
l = load(t)
flow.run()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment