Ashton
01/23/2022, 8:29 PMemre
01/23/2022, 9:19 PMfrom prefect import Flow, task, unmapped
@task(log_stdout=True)
def printl(elem, r):
print(f"{elem} is produced by {r}")
@task
def get_gen(end):
return range(end)
with Flow("Test 1") as flow:
g = get_gen(15)
printl.map(g, unmapped(g))
if __name__ == "__main__":
flow.run()
Anna Geller
Ashton
01/23/2022, 10:23 PMAnna Geller
Kevin Kho