diff --git a/test/integration/component/maint/test_redundant_router.py b/test/integration/component/maint/test_redundant_router.py
index 66bb477e046..991fc6f3fbf 100644
--- a/test/integration/component/maint/test_redundant_router.py
+++ b/test/integration/component/maint/test_redundant_router.py
@@ -843,7 +843,7 @@ class TestRVRInternals(cloudstackTestCase):
         self.debug(master_router.linklocalip)
 
         # Check eth2 port for master router
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
             result = get_process_status(
                                 self.apiclient.connection.mgtSvr,
                                 22,
@@ -879,7 +879,7 @@ class TestRVRInternals(cloudstackTestCase):
                          )
 
         # Check eth2 port for backup router
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
             result = get_process_status(
                                 self.apiclient.connection.mgtSvr,
                                 22,
diff --git a/test/integration/component/test_VirtualRouter_alerts.py b/test/integration/component/test_VirtualRouter_alerts.py
index e6f0a823fd9..bff12f9c8d3 100644
--- a/test/integration/component/test_VirtualRouter_alerts.py
+++ b/test/integration/component/test_VirtualRouter_alerts.py
@@ -208,7 +208,7 @@ class TestVRServiceFailureAlerting(cloudstackTestCase):
 
         alertSubject = "Monitoring Service on VR " + router.name
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
             result = get_process_status(
                         self.apiclient.connection.mgtSvr,
                         22,
diff --git a/test/integration/component/test_deploy_vm_userdata_reg.py b/test/integration/component/test_deploy_vm_userdata_reg.py
index 1c9f35c579d..31735d28499 100755
--- a/test/integration/component/test_deploy_vm_userdata_reg.py
+++ b/test/integration/component/test_deploy_vm_userdata_reg.py
@@ -179,7 +179,7 @@ class TestDeployVmWithUserData(cloudstackTestCase):
         host.passwd="password"
         cmd="cat /var/www/html/userdata/"+deployVmResponse.ipaddress+"/user-data"
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
 
             try:
                 result = get_process_status(
diff --git a/test/integration/component/test_persistent_networks.py b/test/integration/component/test_persistent_networks.py
index b90d621e622..016a39122bc 100644
--- a/test/integration/component/test_persistent_networks.py
+++ b/test/integration/component/test_persistent_networks.py
@@ -131,8 +131,8 @@ class TestPersistentNetworks(cloudstackTestCase):
 
         hypervisor = str(get_hypervisor_type(self.api_client))
 
-        if hypervisor.lower() == 'vmware':
-            #SSH is done via management server for Vmware
+        if hypervisor.lower() in ('vmware', 'hyperv'):
+            #SSH is done via management server for Vmware and Hyper-V
             sourceip = self.api_client.connection.mgtSvr
         else:
             #For others, we will have to get the ipaddress of host connected to vm
@@ -1410,8 +1410,8 @@ class TestRestartPersistentNetwork(cloudstackTestCase):
 
         hypervisor = str(get_hypervisor_type(self.api_client))
 
-        if hypervisor.lower() == 'vmware':
-            #SSH is done via management server for Vmware
+        if hypervisor.lower() in ('vmware', 'hyperv'):
+            #SSH is done via management server for Vmware and Hyper-V
             sourceip = self.api_client.connection.mgtSvr
         else:
             #For others, we will have to get the ipaddress of host connected to vm
diff --git a/test/integration/smoke/test_routers.py b/test/integration/smoke/test_routers.py
index f77d11a06f8..7d5f267b3ef 100644
--- a/test/integration/smoke/test_routers.py
+++ b/test/integration/smoke/test_routers.py
@@ -148,7 +148,7 @@ class TestRouterServices(cloudstackTestCase):
                             "Check list router response for router state"
                         )
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
                result = get_process_status(
                                    self.apiclient.connection.mgtSvr,
                                    22,
@@ -227,7 +227,7 @@ class TestRouterServices(cloudstackTestCase):
                             "Check list router response for router state"
                         )
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
            result = get_process_status(
                            self.apiclient.connection.mgtSvr,
                                22,
@@ -258,7 +258,7 @@ class TestRouterServices(cloudstackTestCase):
                             "Check dnsmasq service is running or not"
                         )
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
            result = get_process_status(
                                self.apiclient.connection.mgtSvr,
                            22,
@@ -437,7 +437,7 @@ class TestRouterServices(cloudstackTestCase):
                         )
         host = hosts[0]
 
-        if self.hypervisor.lower() == 'vmware':
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
            res = get_process_status(
                            self.apiclient.connection.mgtSvr,
                            22,
diff --git a/test/integration/smoke/test_ssvm.py b/test/integration/smoke/test_ssvm.py
index 9b8d19d0249..ac4079ef48d 100644
--- a/test/integration/smoke/test_ssvm.py
+++ b/test/integration/smoke/test_ssvm.py
@@ -319,8 +319,8 @@ class TestSSVMs(cloudstackTestCase):
 
         self.debug("Running SSVM check script")
 
-        if self.hypervisor.lower() == 'vmware':
-            #SSH into SSVMs is done via management server for Vmware
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
+            #SSH into SSVMs is done via management server for Vmware and Hyper-V
             result = get_process_status(
                                 self.apiclient.connection.mgtSvr,
                                 22,
@@ -359,8 +359,8 @@ class TestSSVMs(cloudstackTestCase):
                         )
 
         #Check status of cloud service
-        if self.hypervisor.lower() == 'vmware':
-            #SSH into SSVMs is done via management server for Vmware
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
+            #SSH into SSVMs is done via management server for Vmware and Hyper-V
             result = get_process_status(
                                 self.apiclient.connection.mgtSvr,
                                 22,
@@ -443,8 +443,8 @@ class TestSSVMs(cloudstackTestCase):
 
         self.debug("Checking cloud process status")
 
-        if self.hypervisor.lower() == 'vmware':
-            #SSH into SSVMs is done via management server for vmware
+        if self.hypervisor.lower() in ('vmware', 'hyperv'):
+            #SSH into SSVMs is done via management server for Vmware and Hyper-V
             result = get_process_status(
                                 self.apiclient.connection.mgtSvr,
                                 22,