fix: Correctly scope async eventloop

integration/test_firestore_async.py

@@ -34,7 +34,7 @@
  }
 
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_firestore_async():
  client = firestore_async.client()
  expected = _CITY
@@ -48,7 +48,7 @@ async def test_firestore_async():
  data = await doc.get()
  assert data.exists is False
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_firestore_async_explicit_database_id():
  client = firestore_async.client(database_id='testing-database')
  expected = _CITY
@@ -62,7 +62,7 @@ async def test_firestore_async_explicit_database_id():
  data = await doc.get()
  assert data.exists is False
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_firestore_async_multi_db():
  city_client = firestore_async.client()
  movie_client = firestore_async.client(database_id='testing-database')
@@ -98,7 +98,7 @@ async def test_firestore_async_multi_db():
  assert data[0].exists is False
  assert data[1].exists is False
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_server_timestamp():
  client = firestore_async.client()
  expected = {

integration/test_messaging.py

@@ -157,7 +157,7 @@ def test_unsubscribe():
  resp = messaging.unsubscribe_from_topic(_REGISTRATION_TOKEN, 'mock-topic')
  assert resp.success_count + resp.failure_count == 1
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_send_each_async():
  messages = [
  messaging.Message(
@@ -189,7 +189,7 @@ async def test_send_each_async():
  assert isinstance(response.exception, exceptions.InvalidArgumentError)
  assert response.message_id is None
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_send_each_async_500():
  messages = []
  for msg_number in range(500):
@@ -206,7 +206,7 @@ async def test_send_each_async_500():
  assert response.exception is None
  assert re.match('^projects/.*/messages/.*$', response.message_id)
 
-@pytest.mark.asyncio
+@pytest.mark.asyncio(loop_scope="session")
 async def test_send_each_for_multicast_async():
  multicast = messaging.MulticastMessage(
  notification=messaging.Notification('Title', 'Body'),

setup.cfg

@@ -1,4 +1,4 @@
 [tool:pytest]
 testpaths = tests
-asyncio_default_test_loop_scope = session
+asyncio_default_test_loop_scope = class
 asyncio_default_fixture_loop_scope = None