removed event loop fixture

Author: cartertinney

tests/e2e/iothub_e2e/aio/test_c2d.py

@@ -19,8 +19,9 @@
 class TestReceiveC2d(object):
     @pytest.mark.it("Can receive C2D")
     @pytest.mark.quicktest_suite
-    async def test_receive_c2d(self, client, service_helper, event_loop, leak_tracker):
+    async def test_receive_c2d(self, client, service_helper, leak_tracker):
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         message = json.dumps(get_random_dict())
 

tests/e2e/iothub_e2e/aio/test_connect_disconnect.py

@@ -42,7 +42,7 @@ async def test_connect_disconnect(self, brand_new_client, leak_tracker):
     # see "This assert fails because of initial and secondary disconnects" below
     @pytest.mark.skip(reason="two stage disconnect causes assertion in test code")
     async def test_connect_in_the_middle_of_disconnect(
-        self, brand_new_client, event_loop, service_helper, random_message, leak_tracker
+        self, brand_new_client, service_helper, random_message, leak_tracker
     ):
         """
         Explanation: People will call `connect` inside `on_connection_state_change` handlers.
@@ -52,6 +52,7 @@ async def test_connect_in_the_middle_of_disconnect(
         assert client
 
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         reconnected_event = asyncio.Event()
 
@@ -110,7 +111,6 @@ async def handle_on_connection_state_change():
     async def test_disconnect_in_the_middle_of_connect(
         self,
         brand_new_client,
-        event_loop,
         service_helper,
         random_message,
         first_connect,
@@ -126,6 +126,7 @@ async def test_disconnect_in_the_middle_of_connect(
         disconnect_on_next_connect_event = False
 
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         disconnected_event = asyncio.Event()
 

tests/e2e/iothub_e2e/aio/test_sas_renewal.py

@@ -22,10 +22,9 @@ class TestSasRenewal(object):
     @pytest.mark.it("Renews and reconnects before expiry")
     @pytest.mark.parametrize(*parametrize.connection_retry_disabled_and_enabled)
     @pytest.mark.parametrize(*parametrize.auto_connect_disabled_and_enabled)
-    async def test_sas_renews(
-        self, client, event_loop, service_helper, random_message, leak_tracker
-    ):
+    async def test_sas_renews(self, client, service_helper, random_message, leak_tracker):
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         connected_event = asyncio.Event()
         disconnected_event = asyncio.Event()

tests/e2e/iothub_e2e/aio/test_twin.py

@@ -190,10 +190,9 @@ async def test_updates_reported_if_reject_before_sending(
 class TestDesiredProperties(object):
     @pytest.mark.it("Receives a patch for a simple desired property")
     @pytest.mark.quicktest_suite
-    async def test_receives_simple_desired_patch(
-        self, client, event_loop, service_helper, leak_tracker
-    ):
+    async def test_receives_simple_desired_patch(self, client, service_helper, leak_tracker):
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         received_patch = None
         received = asyncio.Event()

tests/e2e/iothub_e2e/aio/test_twin_stress.py

@@ -157,13 +157,14 @@ async def test_stress_parallel_reported_property_updates(
     )
     @pytest.mark.it("Can receive continuous desired property updates that were sent one-at-a-time")
     async def test_stress_serial_desired_property_updates(
-        self, client, service_helper, toxic, iteration_count, event_loop, leak_tracker
+        self, client, service_helper, toxic, iteration_count, leak_tracker
     ):
         """
         Update desired properties, one at a time, and verify that the desired property arrives
         at the client before the next update.
         """
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         patches = asyncio.Queue()
 
@@ -200,13 +201,14 @@ async def handle_on_patch_received(patch):
         "Can receive continuous desired property updates that may have been sent in parallel"
     )
     async def test_stress_parallel_desired_property_updates(
-        self, client, service_helper, toxic, iteration_count, batch_size, event_loop, leak_tracker
+        self, client, service_helper, toxic, iteration_count, batch_size, leak_tracker
     ):
         """
         Update desired properties in batches. Each batch updates `batch_size` properties,
         with each property being updated in it's own `PATCH`.
         """
         leak_tracker.set_initial_object_list()
+        event_loop = asyncio.get_running_loop()
 
         patches = asyncio.Queue()
 

tests/e2e/iothub_e2e/pytest.ini

@@ -6,7 +6,7 @@ junit_family=xunit2
 junit_log_passing_tests=True
 asyncio_mode=auto
 asyncio_legacy_mode=true
-asyncio_default_fixture_loop_scope = function
+; asyncio_default_fixture_loop_scope = function
 addopts=
     --testdox
     --force-testdox

tests/e2e/provisioning_e2e/pytest.ini

@@ -3,7 +3,6 @@ timeout=30
 testdox_format=plaintext
 asyncio_mode=auto
 asyncio_legacy_mode=true
-asyncio_default_fixture_loop_scope = function
 addopts=
     --testdox
     --force-testdox