jorwoods
06/02/2020, 5:37 PMfrom prefect import Flow, task, unmapped, Parameter
from prefect.engine.results import LocalResult
from prefect.engine.executors import LocalDaskExecutor
import prefect
lr = LocalResult(location='{flow_name}-{task_name}-{map_index}.txt')
@task(log_stdout=True, checkpoint=True,)
def add(x, y):
return x + y
with Flow('iterated map', result=lr) as flow:
y = unmapped(Parameter('y', default=10))
mapped_result = add.map([1, 2, 3], y=y)
flow.run(executor=LocalDaskExecutor())
Chris White
06/02/2020, 5:59 PMexport PREFECT__FLOWS__CHECKPOINTING=true
jorwoods
06/02/2020, 6:22 PM