Skip to content

Commit 571ffa9

Browse files
author
octavia-squidington-iii
committed
Auto-fix lint and format issues
1 parent 9eccc14 commit 571ffa9

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2761,7 +2761,9 @@ def create_state_delegating_retriever(
27612761
client_side_incremental_sync: Optional[Dict[str, Any]] = None,
27622762
transformations: List[RecordTransformation],
27632763
) -> Optional[StateDelegatingRetriever]:
2764-
if not isinstance(stream_slicer, DatetimeBasedCursor) and not isinstance(stream_slicer, PerPartitionCursor):
2764+
if not isinstance(stream_slicer, DatetimeBasedCursor) and not isinstance(
2765+
stream_slicer, PerPartitionCursor
2766+
):
27652767
raise ValueError("StateDelegatingRetriever requires a DatetimeBasedCursor")
27662768

27672769
full_refresh_retriever = self._create_component_from_model(
@@ -2792,7 +2794,7 @@ def create_state_delegating_retriever(
27922794
full_data_retriever=full_refresh_retriever,
27932795
incremental_data_retriever=incremental_retriever,
27942796
cursor=stream_slicer,
2795-
started_with_state=bool(self._connector_state_manager.get_stream_state(name, None))
2797+
started_with_state=bool(self._connector_state_manager.get_stream_state(name, None)),
27962798
)
27972799

27982800
def _create_async_job_status_mapping(

airbyte_cdk/sources/declarative/retrievers/state_delegating_retriever.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -56,9 +56,7 @@ def __setattr__(self, name: str, value: Any) -> None:
5656
@property
5757
def retriever(self) -> Retriever:
5858
return (
59-
self.incremental_data_retriever
60-
if self.started_with_state
61-
else self.full_data_retriever
59+
self.incremental_data_retriever if self.started_with_state else self.full_data_retriever
6260
)
6361

6462
@property

0 commit comments

Comments
 (0)