Author: croberts Date: 2012-12-11 18:17:39 +0000 (Tue, 11 Dec 2012) New Revision: 5578
Modified: branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py Log: Adding task tracker removal task/form.
Modified: branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py =================================================================== --- branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-11 17:09:56 UTC (rev 5577) +++ branches/elephant/cumin/python/cumin/gridhadoop/hadoop.py 2012-12-11 18:17:39 UTC (rev 5578) @@ -79,6 +79,8 @@
self.add_search_filter(self.table.jt_col) self.table.adapter = HadoopAdapter(app, cls, None) + + TaskTrackerDelete(app, self, "taskTracker_delete")
self.enable_csv_export()
@@ -101,6 +103,8 @@ self.add_search_filter(self.table.loc_col) self.table.adapter = HadoopAdapter(app, cls, None)
+ JobTrackerDelete(app, self, "jobTracker_delete") + self.enable_csv_export()
def create_table(self, app, name, cls): @@ -364,5 +368,63 @@
def render_title(self, session): return "Remove data nodes" + +class JobTrackerDelete(ObjectSelectorTask): + def __init__(self, app, selector, name): + super(JobTrackerDelete, self).__init__(app, selector) + cls = app.model.com_redhat_cumin_grid_hadoop.JobTracker + + self.form = JobTrackerDeleteForm(app, self.name, self, cls) + self.invoc = None + + def get_title(self, session): + return "Remove job trackers"
+ def get_item_content(self, session, item): + return xml_escape(item)
+ +class JobTrackerDeleteForm(HadoopNodeDeleteForm): + def process_submit(self, session): + name_nodes_to_kill = self.selection.get(session) + + if not self.errors.get(session): + print "Here is where I'd make a call to kill some job trackers [%s]" % name_nodes_to_kill + #self.task.invoke(session, name_nodes_to_kill) + + url = self.return_url.get(session) + self.page.redirect.set(session, url) + + def render_title(self, session): + return "Remove job trackers" + +class TaskTrackerDelete(ObjectSelectorTask): + def __init__(self, app, selector, name): + super(TaskTrackerDelete, self).__init__(app, selector) + cls = app.model.com_redhat_cumin_grid_hadoop.TaskTracker + + self.form = TaskTrackerDeleteForm(app, self.name, self, cls) + self.invoc = None + + def get_title(self, session): + return "Remove task trackers" + + def get_item_content(self, session, item): + return xml_escape(item) + + +class TaskTrackerDeleteForm(HadoopNodeDeleteForm): + def process_submit(self, session): + name_nodes_to_kill = self.selection.get(session) + + if not self.errors.get(session): + print "Here is where I'd make a call to kill some task trackers [%s]" % name_nodes_to_kill + #self.task.invoke(session, name_nodes_to_kill) + + url = self.return_url.get(session) + self.page.redirect.set(session, url) + + def render_title(self, session): + return "Remove task trackers" + +
cumin-developers@lists.fedorahosted.org