wip

Author: ohmayr

packages/google-cloud-firestore/noxfile.py

@@ -82,6 +82,7 @@
     "pytest-asyncio==0.21.2",
     "six",
     "pyyaml",
+    "pytest-xdist",
 ]
 SYSTEM_TEST_LOCAL_DEPENDENCIES: List[str] = []
 SYSTEM_TEST_DEPENDENCIES: List[str] = []
@@ -402,6 +403,8 @@ def system(session):
     if system_test_exists:
         session.run(
             "py.test",
+            "-n",
+            "auto",
             "--quiet",
             f"--junitxml=system_{session.python}_sponge_log.xml",
             system_test_path,
@@ -410,6 +413,8 @@ def system(session):
     if system_test_folder_exists:
         session.run(
             "py.test",
+            "-n",
+            "auto",
             "--quiet",
             f"--junitxml=system_{session.python}_sponge_log.xml",
             system_test_folder_path,

packages/google-cloud-firestore/tests/system/test_system.py

@@ -1268,7 +1268,7 @@ def test_unicode_doc(client, cleanup, database):
     assert snapshot2.reference.id == explicit_doc_id
 
 
-@pytest.fixture
+@pytest.fixture(scope="module")
 def query_docs(client, database):
     collection_id = "qs" + UNIQUE_RESOURCE_ID
     sub_collection = "child" + UNIQUE_RESOURCE_ID
@@ -1297,13 +1297,13 @@ def query_docs(client, database):
         operation()
 
 
-@pytest.fixture
+@pytest.fixture(scope="module")
 def collection(query_docs):
     collection, _, _ = query_docs
     return collection
 
 
-@pytest.fixture
+@pytest.fixture(scope="module")
 def query(collection):
     return collection.where(filter=FieldFilter("a", "==", 1))
 

packages/google-cloud-firestore/tests/system/test_system_async.py

@@ -1243,7 +1243,7 @@ async def test_list_collections_with_read_time(client, cleanup, database):
     }
 
 
-@pytest_asyncio.fixture
+@pytest_asyncio.fixture(scope="module")
 async def query_docs(client):
     collection_id = "qs" + UNIQUE_RESOURCE_ID
     sub_collection = "child" + UNIQUE_RESOURCE_ID
@@ -1272,13 +1272,13 @@ async def query_docs(client):
         await operation()
 
 
-@pytest_asyncio.fixture
+@pytest_asyncio.fixture(scope="module")
 async def collection(query_docs):
     collection, _, _ = query_docs
     yield collection
 
 
-@pytest_asyncio.fixture
+@pytest_asyncio.fixture(scope="module")
 async def async_query(collection):
     return collection.where(filter=FieldFilter("a", "==", 1))