Sander
05/16/2022, 9:24 AMAnna Geller
05/16/2022, 10:28 AMfrom prefect import flow, task
@task
def do_something_with_path(path: str):
filename = f"{path}/some_data.txt"
data = "Hello world from Prefect 2.0!"
with open(filename, "w") as file:
file.write(data)
return filename
@flow
def parametrized_flow_with_path(path: str):
do_something_with_path(path)
if __name__ == "__main__":
parametrized_flow_with_path(path_val)
then DeploymentSpec:
DeploymentSpec(
flow=parametrized_flow_with_path,
name="staging",
schedule=IntervalSchedule(interval=timedelta(days=1)),
parameters={"path": "/your/path"},
tags=["local"],
)
Sander
05/16/2022, 10:29 AMAnna Geller
05/16/2022, 10:32 AMSander
05/16/2022, 10:33 AMAnna Geller
05/16/2022, 10:35 AMSander
05/16/2022, 10:36 AMAnna Geller
05/16/2022, 10:36 AMSander
05/16/2022, 10:49 AMAnna Geller
05/16/2022, 10:53 AMSander
05/16/2022, 10:54 AMAnna Geller
05/16/2022, 10:55 AMprefect orion start
Sander
05/16/2022, 11:12 AMAnna Geller
05/16/2022, 11:45 AMSander
05/16/2022, 11:48 AMAnna Geller
05/16/2022, 11:49 AMSander
05/16/2022, 11:50 AMAnna Geller
05/16/2022, 11:50 AMSander
05/16/2022, 11:51 AMAnna Geller
05/16/2022, 11:54 AMSander
05/16/2022, 11:54 AMAnna Geller
05/16/2022, 12:00 PMSander
05/16/2022, 12:02 PMAnna Geller
05/16/2022, 12:02 PMSander
05/16/2022, 12:03 PMAnna Geller
05/16/2022, 12:03 PMSander
05/16/2022, 12:07 PMAnna Geller
05/16/2022, 12:43 PMSander
05/17/2022, 8:25 AMAnna Geller
05/17/2022, 11:26 AMSander
05/17/2022, 11:38 AM