ran black

Author: daniel-sanche

google/cloud/firestore_v1/async_pipeline.py

@@ -77,7 +77,12 @@ async def execute(
                 if Point-in-Time Recovery is enabled, can additionally be a whole minute timestamp
                 within the past 7 days. For the most accurate results, use UTC timezone.
         """
-        return [result async for result in self.stream(transaction=transaction, read_time=read_time)]
+        return [
+            result
+            async for result in self.stream(
+                transaction=transaction, read_time=read_time
+            )
+        ]
 
     async def stream(
         self,

google/cloud/firestore_v1/pipeline.py

@@ -74,7 +74,10 @@ def execute(
                 if Point-in-Time Recovery is enabled, can additionally be a whole minute timestamp
                 within the past 7 days. For the most accurate results, use UTC timezone.
         """
-        return [result for result in self.stream(transaction=transaction, read_time=read_time)]
+        return [
+            result
+            for result in self.stream(transaction=transaction, read_time=read_time)
+        ]
 
     def stream(
         self,

tests/system/test_system.py

@@ -1695,7 +1695,6 @@ def test_pipeline_w_read_time(query_docs, cleanup, database):
     collection, stored, allowed_vals = query_docs
     num_vals = len(allowed_vals)
 
-
     # Find a read_time before adding the new document.
     snapshots = collection.get()
     read_time = snapshots[0].read_time

tests/system/test_system_async.py

@@ -1611,6 +1611,7 @@ async def test_query_stream_w_read_time(query_docs, cleanup, database):
     assert new_ref.id in new_values
     assert new_values[new_ref.id] == new_data
 
+
 @pytest.mark.skipif(IS_KOKORO_TEST, reason="skipping pipeline verification on kokoro")
 @pytest.mark.parametrize("database", [FIRESTORE_ENTERPRISE_DB], indirect=True)
 async def test_pipeline_w_read_time(query_docs, cleanup, database):