Skip to content

Commit

Permalink
Added type ignore to correct location
Browse files Browse the repository at this point in the history
  • Loading branch information
jamielxcarter committed Nov 14, 2023
1 parent 4820a35 commit a407e00
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions singer_sdk/sinks/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit a407e00

Please sign in to comment.