Skip to content
Snippets Groups Projects

deploy_twamp: additional check step

Merged Aleksandr Kurbatov requested to merge iptrunk_twamp_check into develop
2 files
+ 21
2
Compare changes
  • Side-by-side
  • Inline
Files
2
@@ -77,6 +77,24 @@ def deploy_twamp_real(subscription: Iptrunk, process_id: UUIDstr, callback_route
return {"subscription": subscription}
@step("Check TWAMP status on both sides")
def check_twamp_status(subscription: Iptrunk, callback_route: str) -> State:
"""Check TWAMP session."""
extra_vars = {
"subscription": json.loads(json_dumps(subscription)),
"verb": "check_twamp",
}
inventory = (
f"{subscription.iptrunk.iptrunk_sides[0].iptrunk_side_node.router_fqdn}"
f"\n{subscription.iptrunk.iptrunk_sides[1].iptrunk_side_node.router_fqdn}"
)
execute_playbook("deploy_twamp.yaml", callback_route, inventory, extra_vars)
return {"subscription": subscription}
@workflow(
"Deploy TWAMP",
initial_input_form=wrap_modify_initial_input_form(_initial_input_form_generator),
@@ -93,6 +111,7 @@ def deploy_twamp() -> StepList:
>> unsync
>> lso_interaction(deploy_twamp_dry)
>> lso_interaction(deploy_twamp_real)
>> lso_interaction(check_twamp_status)
>> resync
>> done
)
Loading