dmlc--dgl
44089c8b4d
* Merge * [Graph][CUDA] Graph on GPU and many refactoring (#1791) * change edge_ids behavior and C++ impl * fix unittests; remove utils.Index in edge_id * pass mx and th tests * pass tf test * add aten::Scatter_ * Add nonzero; impl CSRGetDataAndIndices/CSRSliceMatrix * CSRGetData and CSRGetDataAndIndices passed tests * CSRSliceMatrix basic tests * fix bug in empty slice * CUDA CSRHasDuplicate * has_node; has_edge_between * predecessors, successors * deprecate send/recv; fix send_and_recv * deprecate send/recv; fix send_and_recv * in_edges; out_edges; all_edges; apply_edges * in deg/out deg * subgraph/edge_subgraph * adj * in_subgraph/out_subgraph * sample neighbors * set/get_n/e_repr * wip: working on refactoring all idtypes * pass ndata/edata tests on gpu * fix * stash * workaround nonzero issue * stash * nx conversion * test_hetero_basics except update routines * test_update_routines * test_hetero_basics for pytorch * more fixes * WIP: flatten graph * wip: flatten * test_flatten * test_to_device * fix bug in to_homo * fix bug in CSRSliceMatrix * pass subgraph test * fix send_and_recv * fix filter * test_heterograph * passed all pytorch tests * fix mx unittest * fix pytorch test_nn * fix all unittests for PyTorch * passed all mxnet tests * lint * fix tf nn test * pass all tf tests * lint * lint * change deprecation * try fix compile * lint * update METIDS * fix utest * fix * fix utests * try debug * revert * small fix * fix utests * upd * upd * upd * fix * upd * upd * upd * upd * upd * trigger * +1s * [kernel] Use heterograph index instead of unitgraph index (#1813) * upd * upd * upd * fix * upd * upd * upd * upd * upd * trigger * +1s * [Graph] Mutation for Heterograph (#1818) * mutation add_nodes and add_edges * Add support for remove_edges, remove_nodes, add_selfloop, remove_selfloop * Fix Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> * upd * upd * upd * fix * [Transfom] Mutable transform (#1833) * add nodesy * All three * Fix * lint * Add some test case * Fix * Fix * Fix * Fix * Fix * Fix * fix * triger * Fix * fix Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> * [Graph] Migrate Batch & Readout module to heterograph (#1836) * dgl.batch * unbatch * fix to device * reduce readout; segment reduce * change batch_num_nodes|edges to function * reduce readout/ softmax * broadcast * topk * fix * fix tf and mx * fix some ci * fix batch but unbatch differently * new checkk * upd * upd * upd * idtype behavior; code reorg * idtype behavior; code reorg * wip: test_basics * pass test_basics * WIP: from nx/ to nx * missing files * upd * pass test_basics:test_nx_conversion * Fix test * Fix inplace update * WIP: fixing tests * upd * pass test_transform cpu * pass gpu test_transform * pass test_batched_graph * GPU graph auto cast to int32 * missing file * stash * WIP: rgcn-hetero * Fix two datasety * upd * weird * Fix capsuley * fuck you * fuck matthias * Fix dgmg * fix bug in block degrees; pass rgcn-hetero * rgcn * gat and diffpool fix also fix ppi and tu dataset * Tree LSTM * pointcloud * rrn; wip: sgc * resolve conflicts * upd * sgc and reddit dataset * upd * Fix deepwalk, gindt and gcn * fix datasets and sign * optimization * optimization * upd * upd * Fix GIN * fix bug in add_nodes add_edges; tagcn * adaptive sampling and gcmc * upd * upd * fix geometric * fix * metapath2vec * fix agnn * fix pickling problem of block * fix utests * miss file * linegraph * upd * upd * upd * graphsage * stgcn_wave * fix hgt * on unittests * Fix transformer * Fix HAN * passed pytorch unittests * lint * fix * Fix cluster gcn * cluster-gcn is ready * on fixing block related codes * 2nd order derivative * Revert "2nd order derivative" This reverts commit 523bf6c249bee61b51b1ad1babf42aad4167f206. * passed torch utests again * fix all mxnet unittests * delete some useless tests * pass all tf cpu tests * disable * disable distributed unittest * fix * fix * lint * fix * fix * fix script * fix tutorial * fix apply edges bug * fix 2 basics * fix tutorial Co-authored-by: yzh119 <expye@outlook.com> Co-authored-by: xiang song(charlie.song) <classicxsong@gmail.com> Co-authored-by: Ubuntu <ubuntu@ip-172-31-51-214.ec2.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-7-42.us-west-2.compute.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-1-5.us-west-2.compute.internal> Co-authored-by: Ubuntu <ubuntu@ip-172-31-68-185.ec2.internal>
54 行
2.1 KiB
Python
54 行
2.1 KiB
Python
# Beam Search Module
|
|
|
|
from modules import *
|
|
from dataset import *
|
|
from tqdm import tqdm
|
|
import numpy as n
|
|
import argparse
|
|
|
|
k = 5 # Beam size
|
|
|
|
if __name__ == '__main__':
|
|
argparser = argparse.ArgumentParser('testing translation model')
|
|
argparser.add_argument('--gpu', default=-1, help='gpu id')
|
|
argparser.add_argument('--N', default=6, type=int, help='num of layers')
|
|
argparser.add_argument('--dataset', default='multi30k', help='dataset')
|
|
argparser.add_argument('--batch', default=64, help='batch size')
|
|
argparser.add_argument('--universal', action='store_true', help='use universal transformer')
|
|
argparser.add_argument('--checkpoint', type=int, help='checkpoint: you must specify it')
|
|
argparser.add_argument('--print', action='store_true', help='whether to print translated text')
|
|
args = argparser.parse_args()
|
|
args_filter = ['batch', 'gpu', 'print']
|
|
exp_setting = '-'.join('{}'.format(v) for k, v in vars(args).items() if k not in args_filter)
|
|
device = 'cpu' if args.gpu == -1 else 'cuda:{}'.format(args.gpu)
|
|
|
|
dataset = get_dataset(args.dataset)
|
|
V = dataset.vocab_size
|
|
dim_model = 512
|
|
|
|
fpred = open('pred.txt', 'w')
|
|
fref = open('ref.txt', 'w')
|
|
|
|
graph_pool = GraphPool()
|
|
model = make_model(V, V, N=args.N, dim_model=dim_model)
|
|
with open('checkpoints/{}.pkl'.format(exp_setting), 'rb') as f:
|
|
model.load_state_dict(th.load(f, map_location=lambda storage, loc: storage))
|
|
model = model.to(device)
|
|
model.eval()
|
|
test_iter = dataset(graph_pool, mode='test', batch_size=args.batch, device=device, k=k)
|
|
for i, g in enumerate(test_iter):
|
|
with th.no_grad():
|
|
output = model.infer(g, dataset.MAX_LENGTH, dataset.eos_id, k, alpha=0.6)
|
|
for line in dataset.get_sequence(output):
|
|
if args.print:
|
|
print(line)
|
|
print(line, file=fpred)
|
|
for line in dataset.tgt['test']:
|
|
print(line.strip(), file=fref)
|
|
fpred.close()
|
|
fref.close()
|
|
os.system(r'bash scripts/bleu.sh pred.txt ref.txt')
|
|
os.remove('pred.txt')
|
|
os.remove('ref.txt')
|
|
|