Skip to content

Commit 643d950

Browse files
committed
Update stream_response for csv and gzip
1 parent 2ed8636 commit 643d950

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2040,7 +2040,7 @@ def create_json_decoder(model: JsonDecoderModel, config: Config, **kwargs: Any)
20402040
@staticmethod
20412041
def create_csv_decoder(model: CsvDecoderModel, config: Config, **kwargs: Any) -> Decoder:
20422042
return CompositeRawDecoder(
2043-
parser=ModelToComponentFactory._get_parser(model, config), stream_response=False
2043+
parser=ModelToComponentFactory._get_parser(model, config), stream_response=True
20442044
)
20452045

20462046
@staticmethod
@@ -2052,7 +2052,7 @@ def create_jsonl_decoder(model: JsonlDecoderModel, config: Config, **kwargs: Any
20522052
@staticmethod
20532053
def create_gzip_decoder(model: GzipDecoderModel, config: Config, **kwargs: Any) -> Decoder:
20542054
return CompositeRawDecoder(
2055-
parser=ModelToComponentFactory._get_parser(model, config), stream_response=False
2055+
parser=ModelToComponentFactory._get_parser(model, config), stream_response=True
20562056
)
20572057

20582058
@staticmethod

0 commit comments

Comments
 (0)