All new accounts created on Gitlab now require administrator approval. If you invite any collaborators, please let Flux staff know so they can approve the accounts.

Commit a0e16d50 authored by David Johnson's avatar David Johnson

We need caps from user wfa to hadoop nodes to run hadoop jobs.

parent 8ff0db9d
Pipeline #1326 skipped
......@@ -83,6 +83,22 @@ def main():
print "Exception", e
pass
if node:
# Allow it to communicate with us, we'll want to talk to the
# master and maybe other nodes later.
try:
print "Sending flow ->%s to %s" % (myname,name)
p.debug_grant(node,nodes[myname].flow)
#a.rp.send(b.flow)
print "Sending flow ->%s to %s" % (name,myname)
p.debug_grant(me,flow)
#b.rp.send(a.flow)
except:
print "Exception",e
pass
pass
if not service_rp:
try:
service_rp = broker.lookup("hadoop")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment