in storage/s3.py [0:0]
def _generate(self, range_start: int, body: BytesIO, is_gzipped: bool) -> StorageDecoratorIterator:
"""
Concrete implementation of the iterator for get_by_lines
"""
file_ending_offset: int = range_start
def chunk_lambda() -> Any:
return body.read(CHUNK_SIZE)
if is_gzipped:
reader: StorageReader = StorageReader(raw=body)
yield reader, 0, 0, b"", None
else:
for chunk in iter(chunk_lambda, b""):
file_starting_offset = file_ending_offset
file_ending_offset += len(chunk)
shared_logger.debug("_generate flat", extra={"offset": file_ending_offset})
yield chunk, file_ending_offset, file_starting_offset, b"", None