Ihor Bondartcov
10/25/2021, 5:26 PMKevin Kho
Kevin Kho
Kevin Kho
Ihor Bondartcov
10/25/2021, 5:39 PMKevin Kho
from prefect import task, Flow, Parameter
import prefect
@task
def abc(x):
logger = prefect.context.get("logger")
<http://logger.info|logger.info>(x)
<http://logger.info|logger.info>(type(x))
return x
with Flow("param_test") as flow:
test = Parameter("test", [{"1":"a"}, {}])
abc(test)
flow.register("bristech")
Ihor Bondartcov
10/25/2021, 5:42 PMIhor Bondartcov
10/25/2021, 5:43 PMKevin Kho
Kevin Kho