format

airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/cursor.py

@@ -334,7 +334,9 @@ def _calculate_lower_boundary_of_last_slice(self, lower_boundary: CursorValueTyp
             return lower_boundary - self._lookback_window
         return lower_boundary
 
-    def _split_per_slice_range(self, lower: CursorValueType, upper: CursorValueType, upper_is_end: bool) -> Iterable[Tuple[CursorValueType, CursorValueType]]:
+    def _split_per_slice_range(
+        self, lower: CursorValueType, upper: CursorValueType, upper_is_end: bool
+    ) -> Iterable[Tuple[CursorValueType, CursorValueType]]:
         if lower >= upper:
             return
 

airbyte-cdk/python/airbyte_cdk/test/mock_http/request.py

@@ -88,5 +88,10 @@ def __repr__(self) -> str:
 
     def __eq__(self, other: Any) -> bool:
         if isinstance(other, HttpRequest):
-            return self._parsed_url == other._parsed_url and self._query_params == other._query_params and self._headers == other._headers and self._body == other._body
+            return (
+                self._parsed_url == other._parsed_url
+                and self._query_params == other._query_params
+                and self._headers == other._headers
+                and self._body == other._body
+            )
         return False

airbyte-cdk/python/unit_tests/sources/declarative/test_concurrent_declarative_source.py

@@ -5,7 +5,7 @@
 import copy
 import json
 from datetime import datetime, timedelta, timezone
-from typing import Any, Dict, Iterable, List, Mapping, Optional, Union, Tuple
+from typing import Any, Dict, Iterable, List, Mapping, Optional, Tuple, Union
 
 import freezegun
 import isodate