ran blacken

Author: daniel-sanche

tests/unit/v1/test_async_query.py

@@ -827,17 +827,21 @@ async def test_asynccollectiongroup_get_partitions_w_offset():
     with pytest.raises(ValueError):
         [i async for i in query.get_partitions(2)]
 
+
 def test_asyncquery_collection_pipeline_type():
     from google.cloud.firestore_v1.async_pipeline import AsyncPipeline
+
     client = make_async_client()
     parent = client.collection("test")
     query = parent._query()
     ppl = query.pipeline()
     assert isinstance(ppl, AsyncPipeline)
 
+
 def test_asyncquery_collectiongroup_pipeline_type():
     from google.cloud.firestore_v1.async_pipeline import AsyncPipeline
+
     client = make_async_client()
     query = client.collection_group("test")
     ppl = query.pipeline()
-    assert isinstance(ppl, AsyncPipeline)
+    assert isinstance(ppl, AsyncPipeline)

tests/unit/v1/test_pipeline_source.py

@@ -53,7 +53,6 @@ def test_collection_w_tuple(self):
         assert isinstance(first_stage, stages.Collection)
         assert first_stage.path == "/a/b/c"
 
-
     def test_collection_group(self):
         instance = self._make_client().pipeline()
         ppl = instance.collection_group("id")

tests/unit/v1/test_query.py

@@ -950,17 +950,21 @@ def test_collection_group_get_partitions_w_offset(database):
     with pytest.raises(ValueError):
         list(query.get_partitions(2))
 
+
 def test_asyncquery_collection_pipeline_type():
     from google.cloud.firestore_v1.pipeline import Pipeline
+
     client = make_client()
     parent = client.collection("test")
     query = parent._query()
     ppl = query.pipeline()
     assert isinstance(ppl, Pipeline)
 
+
 def test_asyncquery_collectiongroup_pipeline_type():
     from google.cloud.firestore_v1.pipeline import Pipeline
+
     client = make_client()
     query = client.collection_group("test")
     ppl = query.pipeline()
-    assert isinstance(ppl, Pipeline)
+    assert isinstance(ppl, Pipeline)