Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion workflows/core_link/create_core_link.py
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ def provision_core_link(
return {"subscription": subscription}


@create_workflow("Create core_link", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_core_link() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/core_link/modify_core_link.py
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,6 @@ def update_core_link_in_nrm(subscription: CoreLink) -> State:
return {"subscription": subscription}


@modify_workflow("Modify core_link", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_core_link() -> StepList:
return begin >> update_subscription >> update_core_link_in_nrm
2 changes: 1 addition & 1 deletion workflows/core_link/terminate_core_link.py
Original file line number Diff line number Diff line change
Expand Up @@ -90,7 +90,7 @@ def deprovision_core_link(
return {"subscription": subscription}


@terminate_workflow("Terminate core_link", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_core_link() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/core_link/validate_core_link.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,6 @@ def validate_core_ports_in_ims(subscription: CoreLink) -> State:
raise AssertionError("Not implemented yet")


@validate_workflow("Validate core_link")
@validate_workflow()
def validate_core_link() -> StepList:
return begin >> validate_core_link_in_ims >> validate_core_ports_in_ims
2 changes: 1 addition & 1 deletion workflows/l2vpn/create_l2vpn.py
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ def provision_l2vpn_in_nrm(subscription: L2vpnProvisioning) -> State:
return {"subscription": subscription}


@create_workflow("Create l2vpn", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_l2vpn() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/l2vpn/modify_l2vpn.py
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ def update_l2vpn_in_nrm(subscription: L2vpn) -> State:
update_l2vpn_in_external_systems = begin >> update_l2vpn_in_nrm


@modify_workflow("Modify l2vpn", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_l2vpn() -> StepList:
return begin >> update_subscription >> update_l2vpn_in_external_systems

Expand Down
2 changes: 1 addition & 1 deletion workflows/l2vpn/terminate_l2vpn.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,6 @@ def ims_remove_vlans(subscription: L2vpn) -> None:
remove_saps_in_netbox(saps)


@terminate_workflow("Terminate l2vpn", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_l2vpn() -> StepList:
return begin >> ims_remove_l2vpn >> ims_remove_vlans
2 changes: 1 addition & 1 deletion workflows/l2vpn/validate_l2vpn.py
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,6 @@ def validate_vlans_on_ports_in_ims(subscription: L2vpn) -> State:
raise AssertionError("Not implemented yet")


@validate_workflow("Validate l2vpn")
@validate_workflow()
def validate_l2vpn() -> StepList:
return begin >> validate_l2vpn_in_ims >> validate_l2vpn_terminations_in_ims >> validate_vlans_on_ports_in_ims
2 changes: 1 addition & 1 deletion workflows/node/create_node.py
Original file line number Diff line number Diff line change
Expand Up @@ -147,7 +147,7 @@ def provision_node_in_nrm(subscription: NodeProvisioning) -> State:
return {"subscription": subscription}


@create_workflow("Create node", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_node() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/node/modify_node.py
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,6 @@ def update_node_in_nrm(subscription: Node) -> State:
return {"subscription": subscription}


@modify_workflow("Modify node", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_node() -> StepList:
return begin >> update_subscription >> update_node_in_ims >> update_node_in_nrm
2 changes: 1 addition & 1 deletion workflows/node/modify_sync_ports.py
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ def update_interfaces(
return {"interfaces_added": interfaces_added, "interfaces_deleted": interfaces_deleted}


@modify_workflow("Update node interfaces", initial_input_form=modify_initial_input_form_generator)
@modify_workflow(initial_input_form=modify_initial_input_form_generator)
def modify_sync_ports() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/node/terminate_node.py
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,6 @@ def delete_node_from_ims(ims_id: int) -> State:
return {}


@terminate_workflow("Terminate node", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_node() -> StepList:
return begin >> load_initial_state >> delete_node_from_ims
2 changes: 1 addition & 1 deletion workflows/node/validate_node.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,6 @@ def validate_node_in_ims(subscription: Node) -> State:
return {"payload": expected.dict()}


@validate_workflow("Validate node")
@validate_workflow()
def validate_node() -> StepList:
return begin >> validate_node_in_ims
2 changes: 1 addition & 1 deletion workflows/nsip2p/create_nsip2p.py
Original file line number Diff line number Diff line change
Expand Up @@ -176,7 +176,7 @@ def update_vlans_on_ports(subscription: Nsip2pProvisioning) -> State:
# If further customization is needed for NSIP2P, add/override steps here


@create_workflow("Create NSIP2P", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_nsip2p() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/nsip2p/modify_nsip2p.py
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@ def update_nsip2p_in_nrm(subscription: Nsip2p) -> State:
update_nsip2p_in_external_systems = begin >> update_nsip2p_in_nrm


@modify_workflow("Modify NSIP2P", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_nsip2p() -> StepList:
return begin >> update_subscription >> update_nsip2p_in_external_systems

Expand Down
2 changes: 1 addition & 1 deletion workflows/nsip2p/terminate_nsip2p.py
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,6 @@ def ims_remove_vlans(subscription: Nsip2p) -> None:
remove_saps_in_netbox(saps)


@terminate_workflow("Terminate NSIP2P", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_nsip2p() -> StepList:
return begin >> ims_remove_nsip2p >> ims_remove_vlans
2 changes: 1 addition & 1 deletion workflows/nsip2p/validate_nsip2p.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,6 @@ def validate_nsip2p_in_ims(subscription: Nsip2p) -> State:
raise AssertionError("NSIP2P validation not implemented")


@validate_workflow("Validate NSIP2P")
@validate_workflow()
def validate_nsip2p() -> StepList:
return begin >> validate_nsip2p_in_ims
2 changes: 1 addition & 1 deletion workflows/nsistp/create_nsistp.py
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,6 @@ def construct_nsistp_model(
}


@create_workflow("Create nsistp", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_nsistp() -> StepList:
return begin >> construct_nsistp_model >> store_process_subscription(Target.CREATE)
2 changes: 1 addition & 1 deletion workflows/nsistp/modify_nsistp.py
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,6 @@ def update_subscription(
return {"subscription": subscription}


@modify_workflow("Modify nsistp", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_nsistp() -> StepList:
return begin >> update_subscription
2 changes: 1 addition & 1 deletion workflows/nsistp/terminate_nsistp.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ class TerminateNsistpForm(FormPage):
return TerminateNsistpForm


@terminate_workflow("Terminate nsistp", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_nsistp() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/nsistp/validate_nsistp.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,6 @@ def load_initial_state_nsistp(subscription: Nsistp) -> State:
}


@validate_workflow("Validate nsistp")
@validate_workflow()
def validate_nsistp() -> StepList:
return begin >> load_initial_state_nsistp
2 changes: 1 addition & 1 deletion workflows/port/create_port.py
Original file line number Diff line number Diff line change
Expand Up @@ -151,7 +151,7 @@ def provision_port(
return {"subscription": subscription}


@create_workflow("Create port", initial_input_form=initial_input_form_generator)
@create_workflow(initial_input_form=initial_input_form_generator)
def create_port() -> StepList:
return (
begin
Expand Down
2 changes: 1 addition & 1 deletion workflows/port/modify_port.py
Original file line number Diff line number Diff line change
Expand Up @@ -72,6 +72,6 @@ def update_port_in_nrm(subscription: Port) -> State:
return {"subscription": subscription}


@modify_workflow("Modify port", initial_input_form=initial_input_form_generator)
@modify_workflow(initial_input_form=initial_input_form_generator)
def modify_port() -> StepList:
return begin >> update_subscription >> update_port_in_ims >> update_port_in_nrm
2 changes: 1 addition & 1 deletion workflows/port/terminate_port.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,6 +42,6 @@ def release_port(subscription: PortProvisioning) -> State:
return {"subscription": subscription}


@terminate_workflow("Terminate port", initial_input_form=terminate_initial_input_form_generator)
@terminate_workflow(initial_input_form=terminate_initial_input_form_generator)
def terminate_port() -> StepList:
return begin >> set_status(SubscriptionLifecycle.PROVISIONING) >> release_port >> update_port_in_ims
2 changes: 1 addition & 1 deletion workflows/port/validate_port.py
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,6 @@ def validate_port_in_ims(subscription: Port) -> State:
return {"payload": expected.dict()}


@validate_workflow("Validate port")
@validate_workflow()
def validate_port() -> StepList:
return begin >> validate_port_in_ims
Loading