def estimate_reduce(interface, state, label, inp):
    centers = {}
    for i, c in inp:
        centers[i] = c if i not in centers else state['update'](centers[i], c)

    out = interface.output(0)
    for i, c in centers.items():
        out.add(i, state['finalize'](c))
Test XMLRPC
dataset/ETHPy150Open romanorac/discomll/discomll/clustering/kmeans.py/estimate_reduce--crossover with--dataset/ETHPy150Open cjlee112/pygr/tests/metabase_test.py/XMLRPC_Test.test_xmlrpc