import uwsgi


def application(e, s):

    node = uwsgi.cluster_best_node()
    print node

    if not node:
        print "sorry node unavailable"
        raise StopIteration

    for part in uwsgi.send_message(node, 0, 0, e, 0, e['wsgi.input'].fileno(), uwsgi.cl()):
        yield part