Matthias
03/25/2022, 1:49 PMKevin Kho
flow
so it’s not a task@flow
def abc(x: int, y:int):
....
it’s x and y hereMatthias
03/25/2022, 2:07 PMKevin Kho
Matthias
03/26/2022, 7:22 AMKevin Kho
from prefect import flow, task
from prefect.deployments import DeploymentSpec
from datetime import timedelta
@task
def abc(x):
return x+1
@flow
def myflow(x:int):
abc(x)
DeploymentSpec(
flow=myflow,
name="hello-world-daily",
parameters={"x": 1}
)
Matthias
03/26/2022, 7:45 PM