diff --git a/gso/workflows/device/insert_in_ibgp.py b/gso/workflows/device/insert_in_ibgp.py index 15517f3498ae4527a70e458086cb63b9587fcb70..8cdbc557389dc7bb8b58dc8653fbd81a533656bd 100644 --- a/gso/workflows/device/insert_in_ibgp.py +++ b/gso/workflows/device/insert_in_ibgp.py @@ -1,28 +1,28 @@ -#import ipaddress -#import re -#from uuid import uuid4 +# import ipaddress +# import re +# from uuid import uuid4 # -#from orchestrator.db.models import ProductTable, SubscriptionTable +# from orchestrator.db.models import ProductTable, SubscriptionTable # ## noinspection PyProtectedMember -#from orchestrator.forms import FormPage -#from orchestrator.forms.validators import Choice -#from orchestrator.targets import Target -#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, store_process_subscription, unsync +# from orchestrator.forms import FormPage +# from orchestrator.forms.validators import Choice +# from orchestrator.targets import Target +# 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, store_process_subscription, unsync # -#from orchestrator.workflows.utils import wrap_modify_initial_input_form -#from gso.products.product_blocks import device as device_pb -#from gso.products.product_types import device -#from gso.products.product_types.device import ( +# from orchestrator.workflows.utils import wrap_modify_initial_input_form +# from gso.products.product_blocks import device as device_pb +# from gso.products.product_types import device +# from gso.products.product_types.device import ( # Device, -#) -#from gso.products.product_types.site import Site -#from gso.services import _ipam +# ) +# from gso.products.product_types.site import Site +# from gso.services import _ipam # -#def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: +# def initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: # subscription = Device.from_subscription(subscription_id) # # class SimoneDeviceForm(FormPage): @@ -33,8 +33,8 @@ # # return user_input.dict() # -#@step("Show the devices") -#def display_devices() -> State: +# @step("Show the devices") +# def display_devices() -> State: # devices = [] # for subscription_id in ( # SubscriptionTable.query.join(ProductTable) @@ -65,15 +65,15 @@ # } # # -#@workflow( +# @workflow( # "Add node to iBGP", # initial_input_form=wrap_modify_initial_input_form( # initial_input_form_generator # ), # target=Target.MODIFY, -#) +# ) # -#def insert_in_ibgp(): +# def insert_in_ibgp(): # return ( # init # >> store_process_subscription(Target.MODIFY) diff --git a/gso/workflows/iptrunk/create_iptrunk.py b/gso/workflows/iptrunk/create_iptrunk.py index 2c37305a7a1b1d55e25f81434ec9fe73dd1921d5..7e8a5200f106a4b7fe1d14caa5403e6afc5258c9 100644 --- a/gso/workflows/iptrunk/create_iptrunk.py +++ b/gso/workflows/iptrunk/create_iptrunk.py @@ -172,6 +172,7 @@ def provision_ip_trunk_iface_real(subscription: IptrunkProvisioning, process_id: "label_text": "Provisioning a trunk interface, please refresh to get the results of the playbook.", } + @step("Check IP connectivity of the trunk") def check_ip_trunk_connectivity(subscription: IptrunkProvisioning, process_id: UUIDstr) -> State: provisioning_proxy.check_ip_trunk(subscription, process_id, "ping") @@ -181,6 +182,7 @@ def check_ip_trunk_connectivity(subscription: IptrunkProvisioning, process_id: U "label_text": "Checking IP traffic flow on the trunk, to get the results of the playbook.", } + @step("Provision IP trunk ISIS interface [DRY RUN]") def provision_ip_trunk_isis_iface_dry(subscription: IptrunkProvisioning, process_id: UUIDstr) -> State: provisioning_proxy.provision_ip_trunk(subscription, process_id, "isis_interface") @@ -210,6 +212,7 @@ def check_ip_trunk_isis(subscription: IptrunkProvisioning, process_id: UUIDstr) "label_text": "Checking ISIS adjacencies, please refresh to get the results of the playbook.", } + @step("Provision IP trunk LDP interface [DRY RUN]") def provision_ip_trunk_ldp_iface_dry(subscription: IptrunkProvisioning, process_id: UUIDstr) -> State: provisioning_proxy.provision_ip_trunk(subscription, process_id, "ldp_interface")