John Jacoby
11/15/2021, 5:35 PMKevin Kho
John Jacoby
11/15/2021, 6:43 PMKevin Kho
import prefect
from prefect import Flow, task, Parameter
@task
def add_one(x):
x = int(x)
return x + 1
with Flow("param_Test") as flow:
x = Parameter("x", default=["1", "2", "3"])
test = add_one.map(x)
flow.register("bristech")