(self, gid)
| 339 | self.futures["pred_attr"] = self.executor.submit(self._get_pred_attr_cache, gid) |
| 340 | |
| 341 | def _get_node_id_cache(self, gid): |
| 342 | op = dag_utils.report_graph( |
| 343 | self._graph, types_pb2.NODE_ID_CACHE_BY_GID, gid=gid |
| 344 | ) |
| 345 | archive = op.eval() |
| 346 | gid = archive.get_uint64() |
| 347 | node_size = archive.get_uint32() |
| 348 | fp = io.BytesIO(archive.get_bytes()) |
| 349 | node_array = msgpack.load(fp, use_list=False) |
| 350 | return gid, node_size, node_array |
| 351 | |
| 352 | def _get_node_attr_cache(self, gid): |
| 353 | op = dag_utils.report_graph( |
no test coverage detected