fix: re-enable E2E tests

dev_utils/dev_utils/service_helper_sync.py

@@ -258,6 +258,19 @@ def on_event_batch(partition_context, events):
                 for event in events:
                     device_id = get_device_id_from_event(event)
                     module_id = get_module_id_from_event(event)
+                    message_source = get_message_source_from_event(event)
+
+                    # TODO: Remove this verbose logging after debugging twin change event issue
+                    # Log all incoming events with their message source for debugging
+                    logger.info(
+                        "EventHub event received: device_id={}, module_id={}, message_source={}, "
+                        "annotations={}".format(
+                            device_id,
+                            module_id,
+                            message_source,
+                            event.message.annotations if event.message else "N/A",
+                        )
+                    )
 
                     if device_id == self.device_id and module_id == self.module_id:
 

tests/e2e/iothub_e2e/aio/test_twin.py

@@ -18,7 +18,6 @@
 
 
 @pytest.mark.describe("Client Reported Properties")
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestReportedProperties(object):
     @pytest.mark.it("Can set a simple reported property")
     @pytest.mark.quicktest_suite
@@ -116,7 +115,6 @@ async def test_patch_reported_connect_if_necessary(
 @pytest.mark.dropped_connection
 @pytest.mark.describe("Client Reported Properties with dropped connection")
 @pytest.mark.keep_alive(5)
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestReportedPropertiesDroppedConnection(object):
 
     # TODO: split drop tests between first and second patches

tests/e2e/iothub_e2e/sync/test_sync_twin.py

@@ -22,7 +22,6 @@
 class TestReportedProperties(object):
     @pytest.mark.it("Can set a simple reported property")
     @pytest.mark.quicktest_suite
-    @pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
     def test_sync_sends_simple_reported_patch(
         self, client, random_reported_props, service_helper, leak_tracker
     ):
@@ -56,7 +55,6 @@ def thing_that_cant_serialize():
 
     @pytest.mark.it("Can clear a reported property")
     @pytest.mark.quicktest_suite
-    @pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
     def test_sync_clear_property(self, client, random_reported_props, service_helper, leak_tracker):
         leak_tracker.set_initial_object_list()
 
@@ -82,7 +80,6 @@ def test_sync_clear_property(self, client, random_reported_props, service_helper
 
     @pytest.mark.it("Connects the transport if necessary")
     @pytest.mark.quicktest_suite
-    @pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
     def test_sync_patch_reported_connect_if_necessary(
         self, client, random_reported_props, service_helper, leak_tracker
     ):
@@ -109,7 +106,6 @@ def test_sync_patch_reported_connect_if_necessary(
 @pytest.mark.dropped_connection
 @pytest.mark.describe("Client Reported Properties with dropped connection")
 @pytest.mark.keep_alive(5)
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestReportedPropertiesDroppedConnection(object):
 
     # TODO: split drop tests between first and second patches
@@ -176,7 +172,6 @@ def test_sync_updates_reported_if_reject_before_sending(
 
 
 @pytest.mark.describe("Client Desired Properties")
-@pytest.mark.skip(reason="Disabling as tests are failing. Needs investigation.")
 class TestDesiredProperties(object):
     @pytest.mark.it("Receives a patch for a simple desired property")
     @pytest.mark.quicktest_suite