Changeset 91 for trunk

Timestamp:

04/20/05 09:16:52 (18 years ago)

Author:

bastiaans

Message:

plugin/PBSQuery.py:

• Custom version with destructor that kills pbs connection to server

plugin/togap.py:

• Misc

Location:

trunk/plugin

Files:

• PBSQuery.py (added)
• togap.py (modified) (4 diffs)

trunk/plugin/togap.py

@@ -95 +95 @@
                                                 if version_patch < 1:
                                                 
-                                                        incompatbiel = 1
+                                                        incompatible = 1
 
                 return incompatible
@@ -121 +121 @@
                 """Setup appropriate variables"""
 
-                self.pq = PBSQuery()
                 self.jobs = { }
                 self.dp = DataProcessor()
+                self.initPbsQuery()
+
+        def initPbsQuery( self ):
+
+                self.pq = None
+                self.pq = PBSQuery()
 
         def getAttr( self, attrs, name ):
@@ -162 +167 @@
                         jobs = { }
 
+                self.initPbsQuery()
+                time.sleep( 1 )
+                
                 joblist = self.pq.getjobs()
 
@@ -236 +244 @@
                 for jobid, jobattrs in jobs.items():
 
-                        gmetric_val = self.compileGmetricVal( jobid, jobattrs )
-
-                        for val in gmetric_val:
-                                self.dp.multicastGmetric( 'TOGA-JOB-' + jobid, val )
+                        if jobattrs['status'] in [ 'Q', 'R' ]:
+
+                                gmetric_val = self.compileGmetricVal( jobid, jobattrs )
+
+                                for val in gmetric_val:
+                                        self.dp.multicastGmetric( 'TOGA-JOB-' + jobid, val )
 
         def makeNodeString( self, nodelist ):