|
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