Adam
07/08/2022, 2:47 PMKevin Kho
07/08/2022, 2:50 PMAdam
07/08/2022, 2:56 PMKevin Kho
07/08/2022, 2:56 PMAdam
07/08/2022, 2:57 PMKevin Kho
07/08/2022, 3:00 PMAdam
07/08/2022, 7:01 PMKevin Kho
07/08/2022, 7:04 PMAdam
07/08/2022, 7:04 PMKevin Kho
07/08/2022, 7:04 PM@task
def mytask(url):
Adam
07/08/2022, 7:04 PMKevin Kho
07/08/2022, 7:05 PMAdam
07/08/2022, 7:06 PMKevin Kho
07/08/2022, 7:11 PMimport os
os.environ["PREFECT__FLOWS__CHECKPOINTING"] = "true"
from prefect import Flow, task
from prefect.engine.results import LocalResult
@task(result=LocalResult("/Users/kevinkho/Work/scratch"), target="{x}.txt")
def abc(x):
return x
with Flow("test") as flow:
abc.map(["a","b","c"])
flow.run()
Adam
07/08/2022, 7:13 PMKevin Kho
07/08/2022, 7:14 PM