diff --git a/singer_sdk/sinks/core.py b/singer_sdk/sinks/core.py index c77f978b9..9fd87a98b 100644 --- a/singer_sdk/sinks/core.py +++ b/singer_sdk/sinks/core.py @@ -533,9 +533,9 @@ def process_batch_files( mode="rb", ) as file: context_file = ( - gzip_open(file) if encoding.compression == "gzip" else file # type: ignore[attr-defined] + gzip_open(file) if encoding.compression == "gzip" else file ) - context = {"records": [json.loads(line) for line in context_file]} + context = {"records": [json.loads(line) for line in context_file]} # type: ignore[attr-defined] self.process_batch(context) elif spec and encoding.format == BatchFileFormat.PARQUET: with storage.fs(create=False) as batch_fs, batch_fs.open(