Method _get_pred_cache

python/graphscope/nx/classes/cache.py:370–376

(self, gid)

        return gid, succ_cache

    def _get_pred_cache(self, gid):
        op = dag_utils.report_graph(self._graph, types_pb2.PRED_BY_GID, gid=gid)
        archive = op.eval()
        gid = archive.get_uint64()
        fp = io.BytesIO(archive.get_bytes())
        pred_cache = msgpack.load(fp, use_list=False)
        return gid, pred_cache

    def _get_succ_attr_cache(self, gid):
        op = dag_utils.report_graph(self._graph, types_pb2.SUCC_ATTR_BY_GID, gid=gid)