Matthias
Kevin Kho
flow
@flow def abc(x: int, y:int): ....
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} )
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.