dmlc--dgl
Quan (Andy) Gan
e19cd62ecd
* test basics * batched graph & filter, mxnet filter fix * frame and function; bugfix * test graph adj and inc matrices * fixing start = 0 for mxnet * test index * inplace update & line graph * multi send recv * more tests * oops * more tests * removing old test files; readonly graphs for mxnet still kept * modifying test scripts * adding a placeholder for pytorch to reserve directory * torch 0.4.1 compat fixes * moving backend out of compute to avoid nose detection * tests guide * mx sparse-to-dense/sparse-to-numpy is buggy * oops * contribution guide for unit tests * printing incmat * printing dlpack * small push * typo * fixing duplicate entries that causes undefined behavior * move equal comparison to backend
55 行
1.6 KiB
Python
55 行
1.6 KiB
Python
import dgl
|
|
import dgl.function as fn
|
|
import backend as F
|
|
|
|
def generate_graph():
|
|
g = dgl.DGLGraph()
|
|
g.add_nodes(10) # 10 nodes.
|
|
h = F.astype(F.arange(1, 11), F.float32)
|
|
g.ndata['h'] = h
|
|
# create a graph where 0 is the source and 9 is the sink
|
|
for i in range(1, 9):
|
|
g.add_edge(0, i)
|
|
g.add_edge(i, 9)
|
|
# add a back flow from 9 to 0
|
|
g.add_edge(9, 0)
|
|
h = F.tensor([1., 2., 1., 3., 1., 4., 1., 5., 1., 6.,\
|
|
1., 7., 1., 8., 1., 9., 10.])
|
|
g.edata['h'] = h
|
|
return g
|
|
|
|
def reducer_both(nodes):
|
|
return {'h' : F.sum(nodes.mailbox['m'], 1)}
|
|
|
|
def test_copy_src():
|
|
# copy_src with both fields
|
|
g = generate_graph()
|
|
g.register_message_func(fn.copy_src(src='h', out='m'))
|
|
g.register_reduce_func(reducer_both)
|
|
g.update_all()
|
|
assert F.allclose(g.ndata['h'],
|
|
F.tensor([10., 1., 1., 1., 1., 1., 1., 1., 1., 44.]))
|
|
|
|
def test_copy_edge():
|
|
# copy_edge with both fields
|
|
g = generate_graph()
|
|
g.register_message_func(fn.copy_edge(edge='h', out='m'))
|
|
g.register_reduce_func(reducer_both)
|
|
g.update_all()
|
|
assert F.allclose(g.ndata['h'],
|
|
F.tensor([10., 1., 1., 1., 1., 1., 1., 1., 1., 44.]))
|
|
|
|
def test_src_mul_edge():
|
|
# src_mul_edge with all fields
|
|
g = generate_graph()
|
|
g.register_message_func(fn.src_mul_edge(src='h', edge='h', out='m'))
|
|
g.register_reduce_func(reducer_both)
|
|
g.update_all()
|
|
assert F.allclose(g.ndata['h'],
|
|
F.tensor([100., 1., 1., 1., 1., 1., 1., 1., 1., 284.]))
|
|
|
|
if __name__ == '__main__':
|
|
test_copy_src()
|
|
test_copy_edge()
|
|
test_src_mul_edge()
|