Function decompress_gzip

src/pystack/process.py:158–180

Decompresses a Gzip file and writes the contents to a temporary file. Args: filename: The path to the gzip file to decompress. chunk_size: Size of chunks to read and write at a time; defaults to 4MB. Returns: The path to the temporary file containing the decompresse

(
    filename: pathlib.Path, chunk_size: int = 4 * 1024 * 1024
)

def decompress_gzip(
    filename: pathlib.Path, chunk_size: int = 4 * 1024 * 1024
) -> pathlib.Path:
    """Decompresses a Gzip file and writes the contents to a temporary file.

    Args:
        filename: The path to the gzip file to decompress.
        chunk_size: Size of chunks to read and write at a time; defaults to 4MB.

    Returns:
        The path to the temporary file containing the decompressed data.

    Raises:
        gzip.BadGzipFile: If the file is not a valid gzip file.
    """
    with tempfile.NamedTemporaryFile(delete=False) as temp_file:
        with gzip.open(filename, "rb") as file_handle:
            while True:
                chunk = file_handle.read(chunk_size)
                if not chunk:
                    break
                temp_file.write(chunk)
    return pathlib.Path(temp_file.name)