chore(tests): disable pipeline tests in emulator

Author: daniel-sanche

tests/system/test_pipeline_acceptance.py

@@ -34,9 +34,15 @@
 from google.cloud.firestore import Client, AsyncClient
 
 from test__helpers import FIRESTORE_ENTERPRISE_DB
+from test__helpers import FIRESTORE_EMULATOR
 
 FIRESTORE_PROJECT = os.environ.get("GCLOUD_PROJECT")
 
+pytestmark = pytest.mark.skipif(
+    condition=FIRESTORE_EMULATOR,
+    reason="Pipeline tests are currently not supported by emulator",
+)
+
 test_dir_name = os.path.dirname(__file__)
 
 id_format = (

tests/system/test_system.py

@@ -94,6 +94,9 @@ def verify_pipeline(query):
     """
     from google.cloud.firestore_v1.base_aggregation import BaseAggregationQuery
 
+    if FIRESTORE_EMULATOR:
+        pytest.skip("skip pipeline verification on emulator")
+
     def _clean_results(results):
         if isinstance(results, dict):
             return {k: _clean_results(v) for k, v in results.items()}

tests/system/test_system_async.py

@@ -174,6 +174,9 @@ async def verify_pipeline(query):
     """
     from google.cloud.firestore_v1.base_aggregation import BaseAggregationQuery
 
+    if FIRESTORE_EMULATOR:
+        pytest.skip("skip pipeline verification on emulator")
+
     def _clean_results(results):
         if isinstance(results, dict):
             return {k: _clean_results(v) for k, v in results.items()}

tests/unit/v1/test_pipeline_result.py

@@ -484,7 +484,7 @@ async def test_double_iterate(self):
 
         async def async_gen(items):
             for item in items:
-                yield item
+                yield item  # pragma: NO COVER
 
         # mock the api call to avoid real network requests
         instance._client._firestore_api.execute_pipeline = mock.AsyncMock(