Sander
05/16/2022, 9:24 AMAnna Geller
from 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
Sander
05/16/2022, 10:33 AMAnna Geller
Sander
05/16/2022, 10:36 AMAnna Geller
Sander
05/16/2022, 10:49 AMAnna Geller
Sander
05/16/2022, 10:54 AMAnna Geller
prefect orion start
Sander
05/16/2022, 11:12 AMAnna Geller
Sander
05/16/2022, 11:48 AMAnna Geller
Sander
05/16/2022, 11:50 AMAnna Geller
Sander
05/16/2022, 11:51 AMAnna Geller
Sander
05/16/2022, 11:54 AMAnna Geller
Sander
05/16/2022, 12:02 PMAnna Geller
Sander
05/16/2022, 12:03 PMAnna Geller
Sander
05/16/2022, 12:07 PMAnna Geller
Sander
05/17/2022, 8:25 AMAnna Geller
Sander
05/17/2022, 11:38 AM