From 352b8432ad389a394da83a55e5e06d5a7019e112 Mon Sep 17 00:00:00 2001 From: maxi297 Date: Tue, 22 Oct 2024 15:52:23 -0700 Subject: [PATCH] format --- .../airbyte_cdk/sources/streams/concurrent/cursor.py | 4 +++- airbyte-cdk/python/airbyte_cdk/test/mock_http/request.py | 7 ++++++- .../declarative/test_concurrent_declarative_source.py | 2 +- 3 files changed, 10 insertions(+), 3 deletions(-) diff --git a/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/cursor.py b/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/cursor.py index 33b672e81562..21713869c303 100644 --- a/airbyte-cdk/python/airbyte_cdk/sources/streams/concurrent/cursor.py +++ b/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 diff --git a/airbyte-cdk/python/airbyte_cdk/test/mock_http/request.py b/airbyte-cdk/python/airbyte_cdk/test/mock_http/request.py index 8f276913892f..756be23edd06 100644 --- a/airbyte-cdk/python/airbyte_cdk/test/mock_http/request.py +++ b/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 diff --git a/airbyte-cdk/python/unit_tests/sources/declarative/test_concurrent_declarative_source.py b/airbyte-cdk/python/unit_tests/sources/declarative/test_concurrent_declarative_source.py index 0a34d17dbc2f..fd21b1561486 100644 --- a/airbyte-cdk/python/unit_tests/sources/declarative/test_concurrent_declarative_source.py +++ b/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