def decompress_json_lines()

in osci/crawlers/github/events/unpack.py [0:0]


def decompress_json_lines(content: bytes) -> Iterator[dict]:
    json_lines = decompress(content).decode('utf-8')
    for line in json_lines.split('\n'):
        log.debug(f'Try to parse json: {line}')
        try:
            yield json.loads(line, encoding='utf-8')
        except Exception as ex:
            log.error(f'Failed to parse json: {line}. Error: {ex}')