diff --git a/tests/snappi_tests/pfc/test_m2o_fluctuating_lossless.py b/tests/snappi_tests/pfc/test_m2o_fluctuating_lossless.py
index dc356346ab4..06fc06fc9ad 100644
--- a/tests/snappi_tests/pfc/test_m2o_fluctuating_lossless.py
+++ b/tests/snappi_tests/pfc/test_m2o_fluctuating_lossless.py
@@ -12,7 +12,7 @@
 from tests.common.snappi_tests.snappi_test_params import SnappiTestParams
 from tests.snappi_tests.cisco.helper import disable_voq_watchdog                  # noqa: F401
 logger = logging.getLogger(__name__)
-pytestmark = [pytest.mark.topology('multidut-tgen')]
+pytestmark = [pytest.mark.topology('multidut-tgen', 'tgen')]
 
 
 @pytest.fixture(autouse=True, scope='module')
diff --git a/tests/snappi_tests/pfc/test_m2o_oversubscribe_lossy.py b/tests/snappi_tests/pfc/test_m2o_oversubscribe_lossy.py
index 48f70860930..afeb97137ba 100644
--- a/tests/snappi_tests/pfc/test_m2o_oversubscribe_lossy.py
+++ b/tests/snappi_tests/pfc/test_m2o_oversubscribe_lossy.py
@@ -12,7 +12,7 @@
 from tests.common.snappi_tests.snappi_test_params import SnappiTestParams
 from tests.snappi_tests.cisco.helper import disable_voq_watchdog                  # noqa: F401
 logger = logging.getLogger(__name__)
-pytestmark = [pytest.mark.topology('multidut-tgen')]
+pytestmark = [pytest.mark.topology('multidut-tgen', 'tgen')]
 
 
 @pytest.fixture(autouse=True, scope='module')