diff --git a/gso/workflows/site/create_site.py b/gso/workflows/site/create_site.py index a1642ef75e2f583dabeb153b305c17e51d3eff19..aa92be43b8c11bdddf0aa99e819f45916447ffb1 100644 --- a/gso/workflows/site/create_site.py +++ b/gso/workflows/site/create_site.py @@ -2,16 +2,15 @@ from uuid import uuid4 from orchestrator.forms import FormPage from orchestrator.targets import Target -# from orchestrator.workflow import inputstep -# from orchestrator.forms.validators import Accept from orchestrator.types import FormGenerator, State from orchestrator.types import SubscriptionLifecycle, UUIDstr from orchestrator.workflow import done, init, step, workflow from orchestrator.workflows.steps import resync, set_status from orchestrator.workflows.steps import store_process_subscription from orchestrator.workflows.utils import wrap_create_initial_input_form -from gso.products.product_types import site + from gso.products.product_blocks import site as site_pb +from gso.products.product_types import site def initial_input_form_generator(product_name: str) -> FormGenerator: @@ -79,16 +78,16 @@ def initialize_subscription( @workflow( "Create Site", initial_input_form=wrap_create_initial_input_form( - initial_input_form_generator), + initial_input_form_generator), target=Target.CREATE, ) def create_site(): return ( - init - >> create_subscription - >> store_process_subscription(Target.CREATE) - >> initialize_subscription - >> set_status(SubscriptionLifecycle.ACTIVE) - >> resync - >> done + init + >> create_subscription + >> store_process_subscription(Target.CREATE) + >> initialize_subscription + >> set_status(SubscriptionLifecycle.ACTIVE) + >> resync + >> done )