Author: croberts
Date: 2013-01-03 14:46:30 +0000 (Thu, 03 Jan 2013)
New Revision: 5631
Modified:
branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
Log:
Now displaying ipc and id in create dropdowns. also sorting list by id. removing some
unused code
Modified: branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py
===================================================================
--- branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-03 14:43:34 UTC
(rev 5630)
+++ branches/elephant/cumin/python/cumin/gridhadoop/tasktracker.py 2013-01-03 14:46:30 UTC
(rev 5631)
@@ -38,11 +38,7 @@
def render_title(self, session):
return "Hadoop task trackers"
-
- def get_qmf_results(self, session):
- values = self.get_data_values(session)
- return self.table.adapter.get_sage_results(values)
-
+
class TaskTrackerTable(ObjectQmfSelectorTable):
def __init__(self, app, name, cls):
super(TaskTrackerTable, self).__init__(app, name, cls)
@@ -114,7 +110,7 @@
(binfile, owner, hadoophost, count, job_tracker) = args
try:
- self.app.remote.start_task_tracker(hadoophost, float(job_tracker), binfile,
owner, count, invoc.make_callback())
+ self.app.remote.start_task_tracker(hadoophost, job_tracker, binfile, owner,
count, invoc.make_callback())
except Exception, e:
invoc.status = invoc.FAILED
log.debug("Creating task trackers failed", exc_info=True)
@@ -161,7 +157,7 @@
def render_title(self, session):
return "Create task trackers"
- class CountField(StringField):
+ class CountField(IntegerField):
def render_title(self, session):
return "Number of task trackers to start"
@@ -214,14 +210,20 @@
nodes = []
(status, node_list) = self.app.remote.get_job_tracker_list()
for node in node_list:
- nodes.append(node.ref.id)
- return nodes
+ nodes.append(node.ref)
+ return sorted(nodes, cmp=compareHadoopIds)
def render_item_value(self, session, item):
- return item
+ value = None
+ if item.ipc:
+ value = item.ipc
+ else:
+ value = item.id
+ return value
def render_item_content(self, session, item):
- return xml_escape(item)
+ display_string = "%s (%s)" % (item.ipc, item.id)
+ return xml_escape(display_string)
def render_item_selected_attr(self, session, item):
if item == self.param.get(session):
Show replies by date