diff --git a/gso/workflows/iptrunk/validate_iptrunk.py b/gso/workflows/iptrunk/validate_iptrunk.py index 47db625697185f0be1cdfa8e8d6644d50b85e046..2eac8ce4d228a73580b9fe7be318dadb00ffaa08 100644 --- a/gso/workflows/iptrunk/validate_iptrunk.py +++ b/gso/workflows/iptrunk/validate_iptrunk.py @@ -11,7 +11,7 @@ from orchestrator.workflows.utils import wrap_modify_initial_input_form from gso.products.product_types.iptrunk import Iptrunk from gso.services import infoblox -from gso.services.provisioning_proxy import execute_playbook, pp_interaction +from gso.services.lso_client import execute_playbook, lso_interaction @step("Validate IP trunk configuration") @@ -76,7 +76,7 @@ def validate_iptrunk() -> StepList: init >> store_process_subscription(Target.SYSTEM) >> unsync - >> pp_interaction(validate_router_config) + >> lso_interaction(validate_router_config) >> verify_ipam_loopback >> resync >> done diff --git a/gso/workflows/router/validate_router.py b/gso/workflows/router/validate_router.py index d768eb37a0ac29cd8fcbfe35bbda4aa0561febdd..abc23133bcab743b3f04bd10b91de52a4f5fa0d6 100644 --- a/gso/workflows/router/validate_router.py +++ b/gso/workflows/router/validate_router.py @@ -11,7 +11,7 @@ from orchestrator.workflows.utils import wrap_modify_initial_input_form from gso.products.product_types.router import Router from gso.services import infoblox -from gso.services.provisioning_proxy import execute_playbook, pp_interaction +from gso.services.lso_client import execute_playbook, lso_interaction @step("Validate router configuration") @@ -54,7 +54,7 @@ def validate_router() -> StepList: init >> store_process_subscription(Target.SYSTEM) >> unsync - >> pp_interaction(validate_router_config) + >> lso_interaction(validate_router_config) >> verify_ipam_loopback >> resync >> done diff --git a/test/workflows/iptrunk/test_validate_iptrunk.py b/test/workflows/iptrunk/test_validate_iptrunk.py index 8e8990c16289b37cfbcbedfa640edcb21d027245..cad4b52457fc192a2900d764d0924e40899083de 100644 --- a/test/workflows/iptrunk/test_validate_iptrunk.py +++ b/test/workflows/iptrunk/test_validate_iptrunk.py @@ -6,7 +6,7 @@ from infoblox_client import objects from gso.products.product_types.iptrunk import Iptrunk from test.workflows import ( assert_complete, - assert_pp_interaction_success, + assert_lso_interaction_success, extract_state, run_workflow, ) @@ -106,7 +106,7 @@ def test_validate_router_success( state = extract_state(result) subscription_id = state["subscription_id"] - result, step_log = assert_pp_interaction_success(result, process_stat, step_log) + result, step_log = assert_lso_interaction_success(result, process_stat, step_log) assert_complete(result) diff --git a/test/workflows/router/test_validate_router.py b/test/workflows/router/test_validate_router.py index 596176c2092511c5dd7ff4352069ccd3ee286298..c6610c743580947a4ade971a7b34ab68d3ae78d6 100644 --- a/test/workflows/router/test_validate_router.py +++ b/test/workflows/router/test_validate_router.py @@ -6,7 +6,7 @@ from infoblox_client import objects from gso.products.product_types.router import Router from test.workflows import ( assert_complete, - assert_pp_interaction_success, + assert_lso_interaction_success, extract_state, run_workflow, ) @@ -50,7 +50,7 @@ def test_validate_router_success( state = extract_state(result) subscription_id = state["subscription_id"] - result, step_log = assert_pp_interaction_success(result, process_stat, step_log) + result, step_log = assert_lso_interaction_success(result, process_stat, step_log) assert_complete(result)