Changeset 166 for trunk/src

Timestamp:

10/07/08 16:57:53 (16 years ago)

Author:

sil

Message:

src/PBSQuery.py:

• added function get_jobs() in node-class

File:

• trunk/src/PBSQuery.py (modified) (5 diffs)

trunk/src/PBSQuery.py

@@ -87 +87 @@
                 self.con = pbs.pbs_connect(self.server)
                 if self.con < 0:
-                        str = "Could not make an connection with %s\n" %(self.server)
+                        str = "Could not make a connection with %s\n" %(self.server)
                         raise PBSError(str)
 
@@ -96 +96 @@
 
         def _list_2_attrib(self, list):
-                """Convert an python list to an attrib list suitable for pbs"""
+                """Convert a python list to an attrib list suitable for pbs"""
                 self.attribs = pbs.new_attrl( len(list) )
                 i = 0 
@@ -104 +104 @@
 
         def _pbsstr_2_list(self, str, delimiter):
-                """Convert an string to an python list and use delimiter as spit char"""
+                """Convert a string to a python list and use delimiter as spit char"""
                 l = sting.splitfields(str, delimiter)
                 if len(l) > 1:
@@ -110 +110 @@
 
         def _list_2_dict(self, l, class_func):
-                """Convert an pbsstat function list to an class dictionary"""
+                """Convert a pbsstat function list to a class dictionary"""
                 self.d = {}
                 for item in l:
@@ -266 +266 @@
                 else:
                         return self.FALSE
+        
+        def get_jobs(self, unique=None):
+                """Returns a list of the currently running job-id('s) on the node"""
+                jobs = self.get_value('jobs')
+                if jobs:
+                        re.compile('[^\\ /]\\d+[^/.]').findall( jobstring )
+                        if not unique:
+                                return jobs
+                        else:
+                                uniq = {}
+                                for job in jobs:
+                                        uniq[job] = 1
+                                return uniq.keys()
+                return list()
+
+
+
+
 
 class queue(_PBSobject):