Changeset 393 for tbroadcast/HEAD/python/tbroadcast.py

Timestamp:

Mar 22, 2007, 5:57:11 PM (17 years ago)

Author:

garonne

Message:

See C.L 1

File:

• tbroadcast/HEAD/python/tbroadcast.py (modified) (5 diffs)

tbroadcast/HEAD/python/tbroadcast.py

@@ -15 +15 @@
 import commands
 import traceback
+import exceptions
 from threading import BoundedSemaphore
 
@@ -26 +27 @@
 class Scheduler:
 
-    def __init__(self, num_workers=20, file=None, ignore_cycles=False, local=False, output=None, error=None, silent = False, perf=False):
+    def __init__(self, num_workers=20, file=None, ignore_cycles=False, local=False, output=None, error=None, silent = False, perf=False, keep_going=True):
         self.pool            = ThreadPool(num_workers=num_workers)
         self.current_package = self.get_current_package()
@@ -39 +40 @@
         self.silent          = silent
         self.perf            = perf
+        self.keep_going      = keep_going
         if self.perf is not False:
             f = open (self.perf, 'w+')
@@ -450 +452 @@
       self.packages[arg['package']] ['startTime'] = time.time ()                           
       status, output, error, pythonError  = exeCommand(sCmd=cmd, oLineCallback=self.redirectOutput, arg=arg)#,iTimeout = 3600)
+      if not self.keep_going and status > 0:
+        sys.exit(status)   
+                     
       self.packages[arg['package']] ['endTime'] = time.time ()
       if self.perf:
@@ -488 +493 @@
       print '#--------------------------------------------------------------'        
       #print "# Exception occured in request #%s: %s" %(request.requestID, exc_info[1])
-      print "# Exception occured: %s" %(exc_info[1])
+      if exc_info[0]== exceptions.SystemExit:
+        print "Stop execution (No_keep_going option enabled): exit code == %s " %(exc_info[1])  
+        print '#--------------------------------------------------------------'    
+        sys.exit(exc_info[1])
+      print "# Exception occured: %s" %(exc_info[1])      
       print exc_info
       print '#--------------------------------------------------------------'