Author: croberts
Date: 2012-12-13 21:54:54 +0000 (Thu, 13 Dec 2012)
New Revision: 5590
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py
branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
Log:
Initial attempt to wire-in get_hosts and start_name_node
Modified: branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-13 21:24:44 UTC (rev
5589)
+++ branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-13 21:54:54 UTC (rev
5590)
@@ -131,7 +131,7 @@
(session)
def do_get_items(self, session):
- hosts = ["grid2.lab.bos.redhat.com"]
+ hosts = self.app.remote.get_hosts("SCHEDULER", "HADOOP")
return hosts
def render_item_value(self, session, item):
Modified: branches/elephant/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2012-12-13 21:24:44 UTC
(rev 5589)
+++ branches/elephant/cumin/python/cumin/gridhadoop/namenode.py 2012-12-13 21:54:54 UTC
(rev 5590)
@@ -68,16 +68,13 @@
if result == False:
self.invoc.status = self.invoc.FAILED
self.invoc.end()
-
- def fake_call(self, binfile, owner, hadoophost):
- return True
-
+
def do_invoke(self, session, object, invoc, args):
self.invoc = invoc
(binfile, owner, hadoophost) = args
try:
- call_async(self.callback, self.fake_call, binfile, owner, hadoophost)
+ call_async(self.callback, self.app.remote.start_name_node, hadoophost,
binfile, owner)
except Exception, e:
invoc.status = invoc.FAILED
log.debug("Creating name node failed", exc_info=True)
Show replies by date