diff --git a/tests/e2e/iothub_e2e/aio/test_connect_disconnect_stress.py b/tests/e2e/iothub_e2e/aio/test_connect_disconnect_stress.py
index ccd756e4d..0e4e1d2fd 100644
--- a/tests/e2e/iothub_e2e/aio/test_connect_disconnect_stress.py
+++ b/tests/e2e/iothub_e2e/aio/test_connect_disconnect_stress.py
@@ -13,7 +13,6 @@
 
 @pytest.mark.stress
 @pytest.mark.describe("Client object connect/disconnect stress")
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestConnectDisconnectStress(object):
     @pytest.mark.parametrize("iteration_count", [10, 50])
     @pytest.mark.it("Can do many non-overlapped connects and disconnects")
diff --git a/tests/e2e/iothub_e2e/aio/test_send_message_stress.py b/tests/e2e/iothub_e2e/aio/test_send_message_stress.py
index b8e58d4f3..64beb7025 100644
--- a/tests/e2e/iothub_e2e/aio/test_send_message_stress.py
+++ b/tests/e2e/iothub_e2e/aio/test_send_message_stress.py
@@ -39,7 +39,6 @@
 
 @pytest.mark.stress
 @pytest.mark.describe("Client Stress")
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestSendMessageStress(object):
     async def send_and_verify_single_telemetry_message(self, client, service_helper):
         """