diff --git a/dev_utils/dev_utils/service_helper_sync.py b/dev_utils/dev_utils/service_helper_sync.py index 0b7ffcd84..4c8d7e851 100644 --- a/dev_utils/dev_utils/service_helper_sync.py +++ b/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: diff --git a/tests/e2e/iothub_e2e/aio/test_twin.py b/tests/e2e/iothub_e2e/aio/test_twin.py index a530246c8..9f540014a 100644 --- a/tests/e2e/iothub_e2e/aio/test_twin.py +++ b/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 diff --git a/tests/e2e/iothub_e2e/sync/test_sync_twin.py b/tests/e2e/iothub_e2e/sync/test_sync_twin.py index b30d8e5f9..53a0647b9 100644 --- a/tests/e2e/iothub_e2e/sync/test_sync_twin.py +++ b/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