fixed lint

Author: daniel-sanche

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

@@ -133,25 +133,30 @@ def test_pipeline_expected_errors(test_dict, client):
     assert match, f"error '{found_error}' does not match '{error_regex}'"
 
 
-
-def _assert_pipeline_results(got_results, expected_results, expected_approximate_results, expected_count):
+def _assert_pipeline_results(
+    got_results, expected_results, expected_approximate_results, expected_count
+):
     if expected_results:
         assert got_results == expected_results
     if expected_approximate_results is not None:
         tolerance = 1e-4
-        if isinstance(expected_approximate_results, dict) and "data" in expected_approximate_results:
-            if "config" in expected_approximate_results and "absolute_tolerance" in expected_approximate_results["config"]:
+        if (
+            isinstance(expected_approximate_results, dict)
+            and "data" in expected_approximate_results
+        ):
+            if (
+                "config" in expected_approximate_results
+                and "absolute_tolerance" in expected_approximate_results["config"]
+            ):
                 tolerance = expected_approximate_results["config"]["absolute_tolerance"]
             expected_approximate_results = expected_approximate_results["data"]
-            
+
         assert len(got_results) == len(expected_approximate_results), (
             "got unexpected result count"
         )
         for idx in range(len(got_results)):
             expected = expected_approximate_results[idx]
-            assert got_results[idx] == pytest.approx(
-                expected, abs=tolerance
-            )
+            assert got_results[idx] == pytest.approx(expected, abs=tolerance)
     if expected_count is not None:
         assert len(got_results) == expected_count
 
@@ -181,7 +186,9 @@ def test_pipeline_results(test_dict, client):
     pipeline = parse_pipeline(client, test_dict["pipeline"])
     # check if server responds as expected
     got_results = [snapshot.data() for snapshot in pipeline.stream()]
-    _assert_pipeline_results(got_results, expected_results, expected_approximate_results, expected_count)
+    _assert_pipeline_results(
+        got_results, expected_results, expected_approximate_results, expected_count
+    )
     if expected_end_state:
         for doc_path, expected_content in expected_end_state.items():
             doc_ref = client.document(doc_path)
@@ -243,7 +250,9 @@ async def test_pipeline_results_async(test_dict, async_client):
     pipeline = parse_pipeline(async_client, test_dict["pipeline"])
     # check if server responds as expected
     got_results = [snapshot.data() async for snapshot in pipeline.stream()]
-    _assert_pipeline_results(got_results, expected_results, expected_approximate_results, expected_count)
+    _assert_pipeline_results(
+        got_results, expected_results, expected_approximate_results, expected_count
+    )
     if expected_end_state:
         for doc_path, expected_content in expected_end_state.items():
             doc_ref = async_client.document(doc_path)