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