Андрій Демиденко
03/29/2022, 10:32 AMAnna Geller
03/29/2022, 10:37 AMprefect.Client
Also, can you explain the use case a bit more? Perhaps there is some better way of approaching this. Are you trying to build some CI/CD pipeline using this approach?Андрій Демиденко
03/29/2022, 10:45 AMAnna Geller
03/29/2022, 10:49 AMАндрій Демиденко
03/29/2022, 10:49 AMAnna Geller
03/29/2022, 10:51 AMАндрій Демиденко
03/29/2022, 10:53 AMAnna Geller
03/29/2022, 10:56 AMflow.register()
because doing that within a Flow content may lead to unexpected resultsfrom prefect import Client
from prefect import Flow, task
@task(log_stdout=True)
def register_other_flow():
from yourmodule import your_flow_object
Client().register(flow=your_flow_object, project_name="yourproject")
with Flow("xxx") as flow:
register_other_flow()
Андрій Демиденко
03/29/2022, 10:59 AMAnna Geller
03/29/2022, 11:00 AMwith Flow("xxx") as flow:
your_flow_object.register("xxx")
Андрій Демиденко
03/29/2022, 11:03 AMfrom prefect import Flow, task
@task(log_stdout=True)
def register_other_flow():
from yourmodule import run
run()
with Flow("xxx") as flow:
register_other_flow()
yourmodule.py
def run():
# here we conduct the registration
flow.register()
Anna Geller
03/29/2022, 11:05 AMfrom prefect import Client
from prefect import Flow, task
@task(log_stdout=True)
def register_other_flow():
from yourmodule import your_flow_object
Client().register(flow=your_flow_object, project_name="yourproject")
with Flow("xxx") as flow:
register_other_flow()
Андрій Демиденко
03/29/2022, 11:05 AMAnna Geller
03/29/2022, 11:06 AMАндрій Демиденко
03/29/2022, 11:10 AMAnna Geller
03/29/2022, 11:11 AMАндрій Демиденко
03/29/2022, 11:14 AMAnna Geller
03/29/2022, 11:17 AMMarvin
03/29/2022, 11:17 AMАндрій Демиденко
03/29/2022, 11:18 AMAnna Geller
03/29/2022, 6:23 PMprefect register --project yourproject -p /path/to/multiple/flows/
this way you can register both at once with no extra work