File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
airbyte_cdk/sources/declarative/resolvers Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -88,13 +88,11 @@ def resolve_components(
8888 """
8989 kwargs = {"stream_template_config" : stream_template_config }
9090
91- stream_slices = self .retriever .stream_slices () if self .retriever .stream_slicer else [{}]
92-
93- for stream_slice in stream_slices :
94- for components_values in self .retriever .read_records ({}, stream_slice ):
91+ for stream_slice in self .retriever .stream_slices ():
92+ for components_values in self .retriever .read_records (records_schema = {}, stream_slice = stream_slice ):
9593 updated_config = deepcopy (stream_template_config )
9694 kwargs ["components_values" ] = components_values # type: ignore[assignment] # component_values will always be of type Mapping[str, Any]
97- kwargs ["stream_slice" ] = stream_slice
95+ kwargs ["stream_slice" ] = stream_slice # type: ignore[assignment] # stream_slice will always be of type Mapping[str, Any]
9896
9997 for resolved_component in self ._resolved_components :
10098 valid_types = (
You can’t perform that action at this time.
0 commit comments