diff --git a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_bridge.py b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_bridge.py
index 5cbea357..5ba045d2 100644
--- a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_bridge.py
+++ b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_bridge.py
@@ -14,6 +14,7 @@
     tgen_utils_setup_streams,
     tgen_utils_get_loss,
     tgen_utils_start_traffic,
+    tgen_utils_stop_traffic,
     tgen_utils_get_swp_info,
 )
 pytestmark = [pytest.mark.suite_functional_lacp,
@@ -142,6 +143,7 @@ async def test_lacp_routing_over_bridge(testbed):
             raise  # will re-raise the AssertionError
     await tgen_utils_start_traffic(tgen_dev)
     await asyncio.sleep(25)
+    await tgen_utils_stop_traffic(tgen_dev)
 
     # 9. Verify traffic received on bridge
     stats = await tgen_utils_get_traffic_stats(tgen_dev, 'Traffic Item Statistics')
diff --git a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_lacp.py b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_lacp.py
index 5139b88c..a35ab02c 100644
--- a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_lacp.py
+++ b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_lacp.py
@@ -136,10 +136,10 @@ async def test_lacp_routing_over_lacp(testbed):
             raise  # will re-raise the AssertionError
     await tgen_utils_start_traffic(tgen_dev)
     await asyncio.sleep(25)
+    await tgen_utils_stop_traffic(tgen_dev)
 
     # 9. Verify no traffic loss
     stats = await tgen_utils_get_traffic_stats(tgen_dev, 'Traffic Item Statistics')
     for row in stats.Rows:
         err_msg = f"Expected 0.00 loss, actual {float(row['Loss %'])}"
         assert isclose(tgen_utils_get_loss(row), 0.00, abs_tol=0.1), err_msg
-    await tgen_utils_stop_traffic(tgen_dev)
diff --git a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_vlan_device.py b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_vlan_device.py
index 58c0d3cb..49d76c9a 100644
--- a/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_vlan_device.py
+++ b/DentOS_Framework/DentOsTestbed/src/dent_os_testbed/test/test_suite/functional/lacp/test_lacp_routing_over_vlan_device.py
@@ -15,6 +15,7 @@
     tgen_utils_get_traffic_stats,
     tgen_utils_setup_streams,
     tgen_utils_start_traffic,
+    tgen_utils_stop_traffic,
     tgen_utils_get_swp_info,
     tgen_utils_get_loss,
 )
@@ -164,6 +165,7 @@ async def test_lacp_routing_over_vlan_device(testbed):
             raise  # will re-raise the AssertionError
     await tgen_utils_start_traffic(tgen_dev)
     await asyncio.sleep(25)
+    await tgen_utils_stop_traffic(tgen_dev)
 
     # 9. Verify no traffic loss
     stats = await tgen_utils_get_traffic_stats(tgen_dev, 'Traffic Item Statistics')