[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