Skip to content

Commit

Permalink
Auto-fix lint and format issues
Browse files Browse the repository at this point in the history
  • Loading branch information
octavia-squidington-iii committed Feb 12, 2025
1 parent 66001f1 commit 1a4b044
Showing 1 changed file with 6 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1808,7 +1808,7 @@ def _validate_retriever(self, model: DeclarativeStreamModel) -> None:
raise ValueError("Per partition state is not supported yet for AsyncRetriever.")

def _merge_stream_slicers(
self, model: DeclarativeStreamModel, config: Config
self, model: DeclarativeStreamModel, config: Config
) -> Optional[StreamSlicer]:
self._validate_retriever(model)

Expand All @@ -1817,8 +1817,11 @@ def _merge_stream_slicers(
if model.incremental_sync:
return self._build_incremental_cursor(model, stream_slicer, config)

return stream_slicer if self._disable_resumable_full_refresh else self._build_resumable_cursor(model.retriever,
stream_slicer)
return (
stream_slicer
if self._disable_resumable_full_refresh
else self._build_resumable_cursor(model.retriever, stream_slicer)
)

def create_default_error_handler(
self, model: DefaultErrorHandlerModel, config: Config, **kwargs: Any
Expand Down

0 comments on commit 1a4b044

Please sign in to comment.