def __call__(self, nodeA):
    new_node = Op.__call__(self)
    new_node.inputs = [nodeA]
    new_node.name = ('Distributed_Communicate(%s)' % nodeA.name)
    return new_node
def __call__(self, nodeA):
    new_node = Op.__call__(self)
    new_node.inputs = [nodeA]
    new_node.name = ('Distributed_Communicate(%s)' % nodeA.name)
    return new_node