From 1984ef17e3fbdd62888e8642cf41510dcfeda8a0 Mon Sep 17 00:00:00 2001 From: Artem Inzhyyants Date: Thu, 19 Dec 2024 15:17:35 +0100 Subject: [PATCH] Composite Decoder: remove args & kwargs Signed-off-by: Artem Inzhyyants --- .../declarative/decoders/composite_decoder.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/airbyte_cdk/sources/declarative/decoders/composite_decoder.py b/airbyte_cdk/sources/declarative/decoders/composite_decoder.py index 9eea736b..6816875a 100644 --- a/airbyte_cdk/sources/declarative/decoders/composite_decoder.py +++ b/airbyte_cdk/sources/declarative/decoders/composite_decoder.py @@ -19,7 +19,8 @@ class Parser(ABC): @abstractmethod def parse( - self, data: BufferedIOBase, *args, **kwargs + self, + data: BufferedIOBase, ) -> Generator[MutableMapping[str, Any], None, None]: """ Parse data and yield dictionaries. @@ -32,7 +33,8 @@ class GzipParser(Parser): inner_parser: Parser def parse( - self, data: BufferedIOBase, *args, **kwargs + self, + data: BufferedIOBase, ) -> Generator[MutableMapping[str, Any], None, None]: """ Decompress gzipped bytes and pass decompressed data to the inner parser. @@ -46,7 +48,8 @@ class JsonLineParser(Parser): encoding: Optional[str] = "utf-8" def parse( - self, data: BufferedIOBase, *args, **kwargs + self, + data: BufferedIOBase, ) -> Generator[MutableMapping[str, Any], None, None]: for line in data: try: @@ -64,7 +67,8 @@ class CsvParser(Parser): delimiter: Optional[str] = "," def parse( - self, data: BufferedIOBase, *args, **kwargs + self, + data: BufferedIOBase, ) -> Generator[MutableMapping[str, Any], None, None]: """ Parse CSV data from decompressed bytes.