Skip to content

Commit 4687726

Browse files
committed
Fix typo
1 parent 864f194 commit 4687726

File tree

2 files changed

+1
-2
lines changed

2 files changed

+1
-2
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1927,7 +1927,7 @@ def _merge_stream_slicers(
19271927
# we could support here by calling create_concurrent_cursor_from_perpartition_cursor
19281928
raise ValueError("Per partition state is not supported yet for AsyncRetriever.")
19291929

1930-
stream_slicer = self._build_stream_slicer_from_partition_router(retriever_model, config)
1930+
stream_slicer = self._build_stream_slicer_from_partition_router(retriever_model, config, stream_name=model.name)
19311931

19321932
if model.incremental_sync:
19331933
return self._build_incremental_cursor(model, stream_slicer, config)

airbyte_cdk/sources/declarative/retrievers/simple_retriever.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -649,7 +649,6 @@ def _read_pages(
649649
stream_slice: StreamSlice,
650650
) -> Iterable[Record]:
651651
response = stream_slice.extra_fields["child_response"]
652-
print(f"LOL, {response.json()}")
653652
if response:
654653
last_page_size, last_record = 0, None
655654
for record in records_generator_fn(response): # type: ignore[call-arg] # only _parse_records expected as a func

0 commit comments

Comments
 (0)