Builder shenanigans

Author: maxi297

airbyte_cdk/sources/declarative/decoders/composite_raw_decoder.py

@@ -176,16 +176,7 @@ def by_headers(
                 parsers_by_header[header] = {header_value: parser for header_value in header_values}
         return cls(fallback_parser, stream_response, parsers_by_header)
 
-    @classmethod
-    def from_parser(cls, parser: Parser, stream_response: bool) -> "CompositeRawDecoder":
-        return cls(parser, stream_response, {})
-
-    def __init__(
-        self,
-        parser: Parser,
-        stream_response: bool = True,
-        parsers_by_header: Optional[Dict[_HEADER, Dict[_HEADER_VALUE, Parser]]] = None,
-    ) -> None:
+    def __init__(self, parser: Parser, stream_response: bool = True, parsers_by_header: Optional[Dict[_HEADER, Dict[_HEADER_VALUE, Parser]]] = None) -> None:
         self._parsers_by_header = parsers_by_header if parsers_by_header else {}
         self._fallback_parser = parser
         self._stream_response = stream_response

airbyte_cdk/sources/declarative/parsers/model_to_component_factory.py

@@ -2216,9 +2216,16 @@ def create_gzip_decoder(
         self, model: GzipDecoderModel, config: Config, **kwargs: Any
     ) -> Decoder:
         gzip_parser: GzipParser = ModelToComponentFactory._get_parser(model, config)  # type: ignore  # based on the model, we know this will be a GzipParser
+
+        if self._emit_connector_builder_messages:
+            # This is very surprising but if the response is not streamed, CompositeRawDecoder calls response.content and the requests library actually uncompress the data as opposed to response.raw which uses urllib3 directly and does not uncompress the data
+            return CompositeRawDecoder(gzip_parser.inner_parser, False)
+        
         return CompositeRawDecoder.by_headers(
-            [({"Content-Encoding", "Content-Type"}, _COMPRESSED_RESPONSE_TYPES, gzip_parser)],
-            stream_response=False if self._emit_connector_builder_messages else True,
+            [
+                ({"Content-Encoding", "Content-Type"}, _COMPRESSED_RESPONSE_TYPES, gzip_parser)
+            ],
+            stream_response=True,
             fallback_parser=gzip_parser.inner_parser,
         )