r5762 - trunk/cumin/python/cumin/gridhadoop

Author: croberts
Date: 2013-06-20 16:29:48 +0000 (Thu, 20 Jun 2013)
New Revision: 5762

Modified:
   trunk/cumin/python/cumin/gridhadoop/jobtracker.py
   trunk/cumin/python/cumin/gridhadoop/namenode.py
Log:
Now passing host to add_external calls.

Modified: trunk/cumin/python/cumin/gridhadoop/jobtracker.py
===================================================================
--- trunk/cumin/python/cumin/gridhadoop/jobtracker.py	2013-06-20 15:20:44 UTC (rev 5761)
+++ trunk/cumin/python/cumin/gridhadoop/jobtracker.py	2013-06-20 16:29:48 UTC (rev 5762)
@@ -101,7 +101,8 @@
     def do_invoke(self, session, object, invoc, args):
         self.invoc = invoc
         (ipc, http) = args
-        self.app.remote.add_external_job_tracker(ipc, http, invoc.make_callback())
+        host = self.app.remote.get_hosts("SCHEDULER", "HADOOP")[0]
+        self.app.remote.add_external_job_tracker(host, ipc, http, invoc.make_callback())
 
     def get_title(self, session, x):
         return "Add an infrastructure job tracker"

Modified: trunk/cumin/python/cumin/gridhadoop/namenode.py
===================================================================
--- trunk/cumin/python/cumin/gridhadoop/namenode.py	2013-06-20 15:20:44 UTC (rev 5761)
+++ trunk/cumin/python/cumin/gridhadoop/namenode.py	2013-06-20 16:29:48 UTC (rev 5762)
@@ -100,7 +100,8 @@
     def do_invoke(self, session, object, invoc, args):
         self.invoc = invoc
         (ipc, http) = args
-        self.app.remote.add_external_name_node(ipc, http, invoc.make_callback())
+        host = self.app.remote.get_hosts("SCHEDULER", "HADOOP")[0]
+        self.app.remote.add_external_name_node(host, ipc, http, invoc.make_callback())
 
     def get_title(self, session, x):
         return "Add an infrastructure name node"