[rhmessaging-commits] rhmessaging commits: r2463 - mgmt/trunk/cumin/python/cumin.
rhmessaging-commits at lists.jboss.org
rhmessaging-commits at lists.jboss.org
Fri Sep 12 15:03:22 EDT 2008
Author: eallen
Date: 2008-09-12 15:03:21 -0400 (Fri, 12 Sep 2008)
New Revision: 2463
Modified:
mgmt/trunk/cumin/python/cumin/scheduler.py
mgmt/trunk/cumin/python/cumin/scheduler.strings
Log:
Added Job tab to scheduler view
Modified: mgmt/trunk/cumin/python/cumin/scheduler.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/scheduler.py 2008-09-12 19:02:29 UTC (rev 2462)
+++ mgmt/trunk/cumin/python/cumin/scheduler.py 2008-09-12 19:03:21 UTC (rev 2463)
@@ -11,6 +11,7 @@
from parameters import *
from formats import *
from util import *
+from job import *
strings = StringCatalog(__file__)
log = logging.getLogger("cumin.scheduler")
@@ -47,7 +48,23 @@
view = SchedulerView(app, "view")
self.add_mode(view)
self.set_view_mode(view)
+
+ def show_job(self, session, job):
+ return self.frame.show_job(session, job)
+
+ def show_job_group(self, session, job_group):
+ return self.frame.show_job_group(session, job_group)
+ def show_jobs_hold(self, session):
+ return self.frame.show_jobs_hold(session)
+
+ def show_jobs_release(self, session):
+ return self.frame.show_jobs_release(session)
+
+ def show_jobs_remove(self, session):
+ return self.frame.show_jobs_remove(session)
+
+
class SchedulerView(CuminView):
def __init__(self, app, name):
super(SchedulerView, self).__init__(app, name)
@@ -61,6 +78,9 @@
stats = SchedulerStats(app, "stats")
self.__tabs.add_tab(stats)
+ jobs = SchedulerJobSet(app, "jobs")
+ self.__tabs.add_tab(jobs)
+
details = CuminDetails(app, "details")
self.__tabs.add_tab(details)
@@ -105,3 +125,36 @@
def render_title(self, session, sched):
return "Jobs"
+
+class SchedulerJobSet(JobSet, Form):
+ def __init__(self, app, name):
+ super(SchedulerJobSet, self).__init__(app, name)
+
+ self.set_default_column_name("global_job_id")
+
+ self.__remove = JobRemoveButton(app, "remove", self)
+ self.add_child(self.__remove)
+
+ self.__hold = JobHoldButton(app, "hold", self)
+ self.add_child(self.__hold)
+
+ self.__release = JobReleaseButton(app, "release", self)
+ self.add_child(self.__release)
+
+ def pre_render(self, session, args):
+ self.show_column(session, "global_job_id")
+ self.show_column(session, "custom_id")
+ self.show_column(session, "cmd")
+ #self.show_column(session, "submitter")
+ self.show_column(session, "custom_group")
+ self.show_column(session, "job_status")
+
+ def render_sql_where(self, session, scheduler):
+ phase_sql = self.get_phase_sql(session)
+ scheduler_sql = "scheduler_id = '%i'" % scheduler.id
+ return "where %s" % " and ".join([phase_sql, scheduler_sql])
+
+ def render_title(self, session, scheduler):
+ where_scheduler = "scheduler_id = %i" % scheduler.id
+ return "Jobs %s" % fmt_count(Job.select(where_scheduler).count())
+
Modified: mgmt/trunk/cumin/python/cumin/scheduler.strings
===================================================================
--- mgmt/trunk/cumin/python/cumin/scheduler.strings 2008-09-12 19:02:29 UTC (rev 2462)
+++ mgmt/trunk/cumin/python/cumin/scheduler.strings 2008-09-12 19:03:21 UTC (rev 2463)
@@ -39,3 +39,28 @@
</tr>
</tbody>
</table>
+
+[SchedulerJobSet.html]
+ <div class="rfloat">{phase}</div>
+<form id="{id}" style="clear:right;" method="post" action="?">
+
+ <div class="sactions">
+ <h2>Act on Selected Jobs:</h2>
+ {hold} {release} {remove}
+ </div>
+
+ <table class="mobjects">
+ <thead>
+ <tr>
+ <th class="setnav" colspan="{column_count}">
+ <div class="rfloat">{page}</div>
+ {count}
+ </th>
+ </tr>
+ <tr>{headers}</tr>
+ </thead>
+ <tbody>{items}</tbody>
+ </table>
+ <div>{hidden_inputs}</div>
+</form>
+
More information about the rhmessaging-commits
mailing list