|
21 | 21 | snappi_portchannel_ipv4_list, snappi_portchannel_ipv6_list, AS_PATHS, \ |
22 | 22 | BGP_TYPE, t1_side_interconnected_port, t2_side_interconnected_port, router_ids, \ |
23 | 23 | snappi_community_for_t1, snappi_community_for_t1_drop, snappi_community_for_t2, num_regionalhubs, \ |
24 | | - SNAPPI_TRIGGER, DUT_TRIGGER, fanout_presence, t2_uplink_fanout_info # noqa: F401 |
| 24 | + SNAPPI_TRIGGER, DUT_TRIGGER, DUT_TRIGGER_SHORT, fanout_presence, t2_uplink_fanout_info # noqa: F401 |
25 | 25 | from tests.common.snappi_tests.variables import v6_prefix_length |
26 | 26 |
|
27 | 27 | logger = logging.getLogger(__name__) |
@@ -1481,6 +1481,11 @@ def get_convergence_for_process_flap(duthosts, |
1481 | 1481 | check_container_status_down(duthost, container, timeout=60) |
1482 | 1482 | check_container_status_up(duthost, container, timeout=DUT_TRIGGER) |
1483 | 1483 | wait(DUT_TRIGGER, "For Flows to be evenly distributed") |
| 1484 | + |
| 1485 | + # execute TSB command, to bring the traffic back |
| 1486 | + duthost.command("sudo TSB") |
| 1487 | + wait(DUT_TRIGGER_SHORT, "For TSB") |
| 1488 | + |
1484 | 1489 | port_stats = get_port_stats(api) |
1485 | 1490 | for port_stat in port_stats: |
1486 | 1491 | if 'Snappi_Tx_Port' not in port_stat.name: |
|
0 commit comments