Changeset 240 for tbroadcast/v2/python/tbroadcast.py

Timestamp:

Aug 28, 2006, 1:20:02 PM (18 years ago)

Author:

garonne

Message:

improve tbroadcast script

File:

• tbroadcast/v2/python/tbroadcast.py (modified) (4 diffs)

tbroadcast/v2/python/tbroadcast.py

@@ -49 +49 @@
     def instanciate_packages(self):
         # We create the schedule of the work units
-        print '# First, we initialize the DAG by parsing cmt show uses (takes a certain time... huk should be improved asap) '
+        print '# First, we initialize the DAG by parsing cmt show uses'
         cmd = 'cmt show uses'
         status, output = commands.getstatusoutput (cmd)
@@ -117 +117 @@
                         sys.exit(-1) 
                     self.packages[result[0]]['path'] = full_path
-        print '# really takes a certain time ... '
+        print '# Sometimes takes a certain time (should be improved asap)'
 
     def get_current_package(self):    
@@ -198 +198 @@
         packages = self.get_next_work_units()
         if len(packages) !=0:
-            print '\n# Execute parallel actions within ', packages                      
+            print '\n#--------------------------------------------------------------'   
+            print '# Execute parallel actions within packages', packages                      
             for package in packages:
                 self.add_work_unit (package, command)
@@ -218 +219 @@
     # the work the threads will have to do 
     def do_execute(self, arg):
-        path = self.get_work_area_path (arg['package'])   
-        self.set_work_unit_status (arg['package'], 'running')      
-        cmd = "cmt -use="+ arg['package'] + " run '"+ arg['cmd'] + "'"
-        os.chdir(path)        
-        print '#--------------------------------------------------------------'
-        print '# Now trying ['+ arg['cmd']+'] in ' + path
-        print '#--------------------------------------------------------------'
-        cmd = arg['cmd']
-        status, output, error, pythonError  = exeCommand(cmd,  iTimeout = 10)      
-        self.suppress_work_unit (arg['package'])
-        self.set_work_unit_status (arg['package'], 'done')
-        # status, output= commands.getstatusoutput(cmd)
-        #print output
-        #if status != 0:
-        #   raise RuntimeError(output)
-        return {'output':output, 'cmd': arg['cmd'], 'package':arg['package']}
+      path = self.get_work_area_path (arg['package'])
+      if path == None:
+          raise RuntimeError('Path to package '+ arg['package'] +' not found')
+      self.set_work_unit_status (arg['package'], 'running')      
+      cmd = "cmt -use="+ arg['package'] + " run '"+ arg['cmd'] + "'"
+      os.chdir(path)        
+      print '#--------------------------------------------------------------'
+      print '# Now trying ['+ arg['cmd']+'] in ' + path
+      print '#--------------------------------------------------------------'
+      cmd = arg['cmd']
+      status, output, error, pythonError  = exeCommand(cmd,  iTimeout = 10)      
+      self.suppress_work_unit (arg['package'])
+      self.set_work_unit_status (arg['package'], 'done')
+      # status, output= commands.getstatusoutput(cmd)
+      #if status != 0:
+      #   raise RuntimeError(output)
+      return {'output':output, 'cmd': arg['cmd'], 'package':arg['package']}
               
     # this will be called when an exception occurs within a thread
     def handle_exception(self, request, exc_info):
         #traceback.print_stack()
-        print "# Exception occured in request #%s: %s" % \
-          (request.requestID, exc_info[1])
+      print '#--------------------------------------------------------------'        
+      #print "# Exception occured in request #%s: %s" %(request.requestID, exc_info[1])
+      print "# Exception occured: %s" %(exc_info[1])
+      print '#--------------------------------------------------------------'    
+      sys.exit(-1)
 #--------- EoF --------#