Skip to content

Instantly share code, notes, and snippets.

Created February 5, 2021 16:10
What would you like to do?
from prefect import Flow, task
def extract():
return [1, 2, 3]
def transform(x):
return [i * 10 for i in x]
def load(y):
print("Received y: {}".format(y))
with Flow("ETL") as flow:
e = extract()
t = transform(e)
l = load(t)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment