9b0a01db41abaab4437649deedf42a1c45e6146c,python/dgl/scheduler.py,,_create_send_and_recv_exec,#Any#,181

Before Change

    rfunc = kwargs.pop("reduce_func")
    if (isinstance(mfunc, fmsg.CopySrcMessageFunction)
            and isinstance(rfunc, fred.SumReducerFunction)
            and _is_spmv_supported_node_feat(graph, mfunc.src_field)):
        // TODO(minjie): more sanity check on field names
        return SendRecvSPMVExecutor(graph,
                                    src=src,

After Change

    else:
        exec_cls = SendRecvExecutor
    if _is_spmv_supported(mfunc, graph) and _is_spmv_supported(rfunc):
        return exec_cls(graph, src=src, dst=dst, mfunc=mfunc, rfunc=rfunc)
    else:
        return None

def get_executor(call_type, graph, **kwargs):

Instances