diff --git a/tests_e2e/tests/agent_bvt/vm_access.py b/tests_e2e/tests/agent_bvt/vm_access.py
index c36aef132..1c231809f 100755
--- a/tests_e2e/tests/agent_bvt/vm_access.py
+++ b/tests_e2e/tests/agent_bvt/vm_access.py
@@ -39,7 +39,7 @@
 class VmAccessBvt(AgentVmTest):
     def run(self):
         ssh_client: SshClient = self._context.create_ssh_client()
-        if not VmExtensionIds.VmAccess.supports_distro(ssh_client.run_command("uname -a")):
+        if not VmExtensionIds.VmAccess.supports_distro(ssh_client.run_command("get_distro.py").rstrip()):
             raise TestSkipped("Currently VMAccess is not supported on this distro")
 
         # Try to use a unique username for each test run (note that we truncate to 32 chars to
diff --git a/tests_e2e/tests/ext_sequencing/ext_sequencing.py b/tests_e2e/tests/ext_sequencing/ext_sequencing.py
index 042ae8a99..e50b0d6ab 100644
--- a/tests_e2e/tests/ext_sequencing/ext_sequencing.py
+++ b/tests_e2e/tests/ext_sequencing/ext_sequencing.py
@@ -159,7 +159,7 @@ def run(self):
         for instance in instances_ip_address:
             ssh_clients[instance.instance_name] = SshClient(ip_address=instance.ip_address, username=self._context.username, identity_file=self._context.identity_file)
 
-        if not VmExtensionIds.AzureMonitorLinuxAgent.supports_distro(next(iter(ssh_clients.values())).run_command("uname -a")):
+        if not VmExtensionIds.AzureMonitorLinuxAgent.supports_distro(next(iter(ssh_clients.values())).run_command("get_distro.py").rstrip()):
             raise TestSkipped("Currently AzureMonitorLinuxAgent is not supported on this distro")
 
         # This is the base ARM template that's used for deploying extensions for this scenario
diff --git a/tests_e2e/tests/ext_telemetry_pipeline/ext_telemetry_pipeline.py b/tests_e2e/tests/ext_telemetry_pipeline/ext_telemetry_pipeline.py
index 809c32f59..01a687f63 100755
--- a/tests_e2e/tests/ext_telemetry_pipeline/ext_telemetry_pipeline.py
+++ b/tests_e2e/tests/ext_telemetry_pipeline/ext_telemetry_pipeline.py
@@ -42,7 +42,7 @@ def run(self):
 
         # Extensions we will create events for
         extensions = ["Microsoft.Azure.Extensions.CustomScript"]
-        if VmExtensionIds.VmAccess.supports_distro(ssh_client.run_command("uname -a")):
+        if VmExtensionIds.VmAccess.supports_distro(ssh_client.run_command("get_distro.py").rstrip()):
             extensions.append("Microsoft.OSTCExtensions.VMAccessForLinux")
 
         # Set the etp collection period to 30 seconds instead of default 5 minutes
diff --git a/tests_e2e/tests/lib/vm_extension_identifier.py b/tests_e2e/tests/lib/vm_extension_identifier.py
index fa304cb76..afbee1e24 100644
--- a/tests_e2e/tests/lib/vm_extension_identifier.py
+++ b/tests_e2e/tests/lib/vm_extension_identifier.py
@@ -34,7 +34,7 @@ def __init__(self, publisher: str, ext_type: str, version: str):
 
     unsupported_distros: Dict[str, List[str]] = {
         "Microsoft.OSTCExtensions.VMAccessForLinux": ["flatcar"],
-        "Microsoft.Azure.Monitor.AzureMonitorLinuxAgent": ["flatcar"]
+        "Microsoft.Azure.Monitor.AzureMonitorLinuxAgent": ["flatcar", "mariner_1"]
     }
 
     def supports_distro(self, system_info: str) -> bool: