diff --git a/airbyte_cdk/sources/declarative/decoders/composite_raw_decoder.py b/airbyte_cdk/sources/declarative/decoders/composite_raw_decoder.py index 60f1407c..49653296 100644 --- a/airbyte_cdk/sources/declarative/decoders/composite_raw_decoder.py +++ b/airbyte_cdk/sources/declarative/decoders/composite_raw_decoder.py @@ -53,7 +53,7 @@ def parse( for line in data: try: yield json.loads(line.decode(encoding=self.encoding or "utf-8")) - except json.JSONDecodeError: + except json.JSONDecodeError as e: logger.warning(f"Cannot decode/parse line {line!r} as JSON, error: {e}")