Skip to content

Commit bbc4bf1

Browse files
committed
initial commit to fix calling transformations twice in asyn retriever
1 parent 2841384 commit bbc4bf1

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3441,11 +3441,14 @@ def create_async_retriever(
34413441
**kwargs: Any,
34423442
) -> AsyncRetriever:
34433443
def _get_download_retriever() -> SimpleRetriever:
3444+
# We create a record selector for the download retriever
3445+
# with no schema normalization and no transformations, neither record filter
3446+
# as all this occurs in the record_selector of the AsyncRetriever
34443447
record_selector = RecordSelector(
34453448
extractor=download_extractor,
34463449
name=name,
34473450
record_filter=None,
3448-
transformations=transformations,
3451+
transformations=[],
34493452
schema_normalization=TypeTransformer(TransformConfig.NoTransform),
34503453
config=config,
34513454
parameters={},

0 commit comments

Comments
 (0)