def loads()

in elasticsearch_serverless/serializer.py [0:0]

• 9 lines of code
• 2 McCabe index (conditional complexity)

        def loads(self, data: bytes) -> pa.Table:
            try:
                with pa.ipc.open_stream(data) as reader:
                    return reader.read_all()
            except pa.ArrowException as e:
                raise SerializationError(
                    message=f"Unable to deserialize as Arrow stream: {data!r}",
                    errors=(e,),
                )