Skip to content
Snippets Groups Projects
Verified Commit 412f4254 authored by Karel van Klink's avatar Karel van Klink :smiley_cat:
Browse files

add TT number and commit comment to TWAMP workflow

parent ddbf1a29
No related branches found
No related tags found
No related merge requests found
This commit is part of merge request !129. Comments created here will be created in the context of that merge request.
""""Workflow for adding TWAMP to an existing IP trunk.""" """Workflow for adding TWAMP to an existing IP trunk."""
from orchestrator.forms import FormPage from orchestrator.forms import FormPage
from orchestrator.forms.validators import Label from orchestrator.forms.validators import Label
...@@ -21,19 +21,21 @@ def _initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator: ...@@ -21,19 +21,21 @@ def _initial_input_form_generator(subscription_id: UUIDstr) -> FormGenerator:
f"{trunk.iptrunk.iptrunk_sides[0].iptrunk_side_node.router_fqdn} to " f"{trunk.iptrunk.iptrunk_sides[0].iptrunk_side_node.router_fqdn} to "
f"{trunk.iptrunk.iptrunk_sides[1].iptrunk_side_node.router_fqdn}" # type: ignore[assignment] f"{trunk.iptrunk.iptrunk_sides[1].iptrunk_side_node.router_fqdn}" # type: ignore[assignment]
) )
tt_number: str
yield DeployTWAMPForm user_input = yield DeployTWAMPForm
return {"subscription": trunk} return user_input.dict()
@step("[DRY RUN] Deploy TWAMP on both sides") @step("[DRY RUN] Deploy TWAMP on both sides")
def deploy_twamp_dry(subscription: Iptrunk, process_id: UUIDstr, callback_route: str) -> State: def deploy_twamp_dry(subscription: Iptrunk, process_id: UUIDstr, callback_route: str, tt_number: str) -> State:
"""Perform a dry run of deploying the TWAMP session.""" """Perform a dry run of deploying the TWAMP session."""
extra_vars = { extra_vars = {
"subscription": subscription, "subscription": subscription,
"process_id": process_id, "process_id": process_id,
"dry_run": True, "dry_run": True,
"commit_comment": f"GSO_PROCESS_ID: {process_id} - TT_NUMBER: {tt_number} - Deploy TWAMP",
} }
inventory = ( inventory = (
...@@ -47,12 +49,13 @@ def deploy_twamp_dry(subscription: Iptrunk, process_id: UUIDstr, callback_route: ...@@ -47,12 +49,13 @@ def deploy_twamp_dry(subscription: Iptrunk, process_id: UUIDstr, callback_route:
@step("[FOR REAL] Deploy TWAMP on both sides") @step("[FOR REAL] Deploy TWAMP on both sides")
def deploy_twamp_real(subscription: Iptrunk, process_id: UUIDstr, callback_route: str) -> State: def deploy_twamp_real(subscription: Iptrunk, process_id: UUIDstr, callback_route: str, tt_number: str) -> State:
"""Deploy the TWAMP session.""" """Deploy the TWAMP session."""
extra_vars = { extra_vars = {
"subscription": subscription, "subscription": subscription,
"process_id": process_id, "process_id": process_id,
"dry_run": False, "dry_run": False,
"commit_comment": f"GSO_PROCESS_ID: {process_id} - TT_NUMBER: {tt_number} - Deploy TWAMP",
} }
inventory = ( inventory = (
......
...@@ -22,7 +22,7 @@ def test_iptrunk_deploy_twamp_success( ...@@ -22,7 +22,7 @@ def test_iptrunk_deploy_twamp_success(
product_id = iptrunk_subscription_factory() product_id = iptrunk_subscription_factory()
# Run workflow # Run workflow
initial_input_data = [{"subscription_id": product_id}, {}] initial_input_data = [{"subscription_id": product_id}, {"tt_number": faker.tt_number()}]
result, process_stat, step_log = run_workflow("deploy_twamp", initial_input_data) result, process_stat, step_log = run_workflow("deploy_twamp", initial_input_data)
for _ in range(2): for _ in range(2):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment