Vamsi Reddy
10/29/2021, 2:02 PMKevin Kho
Vamsi Reddy
10/29/2021, 2:12 PMVamsi Reddy
10/29/2021, 2:13 PMKevin Kho
Kevin 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", "2":"b"})
abc(test)
Kevin Kho
Kevin Kho
Vamsi Reddy
10/29/2021, 3:15 PM