6557291fdc07eca0efaa288e9cba7e3a8345c13d,python/dgl/distributed/dist_graph.py,DistGraph,__init__,#DistGraph#Any#Any#Any#Any#,298

Before Change

                self._g = as_heterograph(g)
            else:
                self._g = None
            self._gpb = get_shared_mem_partition_book(graph_name, self._g)
            if self._gpb is None:
                self._gpb = gpb
            self._client.barrier()
            self._client.map_shared_data(self._gpb)

        self._ndata = NodeDataView(self)

After Change

                self._client.add_data(_get_data_name(name, EDGE_PART_POLICY), edge_feats[name])
            rpc.set_num_client(1)
        else:
            self._init()

        self._ndata = NodeDataView(self)
        self._edata = EdgeDataView(self)

Instances