Skip to content

Commit ead326d

Browse files
author
Oleksandr Bazarnov
committed
reverted operational_decoder to decoder
1 parent dbed4d6 commit ead326d

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2756,7 +2756,7 @@ def _get_download_retriever() -> SimpleRetrieverTestReadDecorator | SimpleRetrie
27562756
paginator = (
27572757
self._create_component_from_model(
27582758
model=model.download_paginator,
2759-
decoder=operational_decoder,
2759+
decoder=decoder,
27602760
config=config,
27612761
url_base="",
27622762
)
@@ -2787,29 +2787,29 @@ def _get_download_retriever() -> SimpleRetrieverTestReadDecorator | SimpleRetrie
27872787
parameters={},
27882788
)
27892789

2790-
operational_decoder = (
2790+
decoder = (
27912791
self._create_component_from_model(model=model.decoder, config=config)
27922792
if model.decoder
27932793
else JsonDecoder(parameters={})
27942794
)
27952795
record_selector = self._create_component_from_model(
27962796
model=model.record_selector,
27972797
config=config,
2798-
decoder=operational_decoder,
2798+
decoder=decoder,
27992799
name=name,
28002800
transformations=transformations,
28012801
client_side_incremental_sync=client_side_incremental_sync,
28022802
)
28032803
stream_slicer = stream_slicer or SinglePartitionRouter(parameters={})
28042804
creation_requester = self._create_component_from_model(
28052805
model=model.creation_requester,
2806-
decoder=operational_decoder,
2806+
decoder=decoder,
28072807
config=config,
28082808
name=f"job creation - {name}",
28092809
)
28102810
polling_requester = self._create_component_from_model(
28112811
model=model.polling_requester,
2812-
decoder=operational_decoder,
2812+
decoder=decoder,
28132813
config=config,
28142814
name=f"job polling - {name}",
28152815
)
@@ -2844,7 +2844,7 @@ def _get_download_retriever() -> SimpleRetrieverTestReadDecorator | SimpleRetrie
28442844
abort_requester = (
28452845
self._create_component_from_model(
28462846
model=model.abort_requester,
2847-
decoder=operational_decoder,
2847+
decoder=decoder,
28482848
config=config,
28492849
name=f"job abort - {name}",
28502850
)
@@ -2854,7 +2854,7 @@ def _get_download_retriever() -> SimpleRetrieverTestReadDecorator | SimpleRetrie
28542854
delete_requester = (
28552855
self._create_component_from_model(
28562856
model=model.delete_requester,
2857-
decoder=operational_decoder,
2857+
decoder=decoder,
28582858
config=config,
28592859
name=f"job delete - {name}",
28602860
)
@@ -2864,19 +2864,19 @@ def _get_download_retriever() -> SimpleRetrieverTestReadDecorator | SimpleRetrie
28642864
download_target_requester = (
28652865
self._create_component_from_model(
28662866
model=model.download_target_requester,
2867-
decoder=operational_decoder,
2867+
decoder=decoder,
28682868
config=config,
28692869
name=f"job extract_url - {name}",
28702870
)
28712871
if model.download_target_requester
28722872
else None
28732873
)
28742874
status_extractor = self._create_component_from_model(
2875-
model=model.status_extractor, decoder=operational_decoder, config=config, name=name
2875+
model=model.status_extractor, decoder=decoder, config=config, name=name
28762876
)
28772877
download_target_extractor = self._create_component_from_model(
28782878
model=model.download_target_extractor,
2879-
decoder=operational_decoder,
2879+
decoder=decoder,
28802880
config=config,
28812881
name=name,
28822882
)

0 commit comments

Comments
 (0)