Xavier Babu
07/21/2022, 9:47 PMAndrew Huang
07/21/2022, 9:59 PM# filename: hello_flow.py
from prefect import flow
@flow
def hello_world(name="world"):
print(f"Hello {name}!")
from prefect.deployments import Deployment
from prefect.deployments import FlowScript
Deployment(
flow=FlowScript(path="/path/to/hello_flow.py", name="hello_world"),
name="Hello World-daily",
schedule=IntervalSchedule(interval=timedelta(days=1)),
parameters={"name": "Arthur"},
tags=["arthur","daily"],
)
Xavier Babu
07/21/2022, 10:34 PMAndrew Huang
07/21/2022, 11:26 PM# filename: hello_flow.py
from prefect import flow
@flow
def hello_world(generic_kwargs=None):
generic_kwargs = generic_kwargs or {}
print("got {len(generic_kwargs)} kwargs!")
hello_world(generic_kwargs=dict(fname="fname", lname="lname"))
something like this?Xavier Babu
07/22/2022, 8:27 PM