Ignore:
Timestamp:
Mar 22, 2007, 5:57:11 PM (17 years ago)
Author:
garonne
Message:

See C.L 1

File:
1 edited

Legend:

Unmodified
Added
Removed
  • tbroadcast/HEAD/python/tbroadcast.py

    r316 r393  
    1515import commands
    1616import traceback
     17import exceptions
    1718from threading import BoundedSemaphore
    1819
     
    2627class Scheduler:
    2728
    28     def __init__(self, num_workers=20, file=None, ignore_cycles=False, local=False, output=None, error=None, silent = False, perf=False):
     29    def __init__(self, num_workers=20, file=None, ignore_cycles=False, local=False, output=None, error=None, silent = False, perf=False, keep_going=True):
    2930        self.pool            = ThreadPool(num_workers=num_workers)
    3031        self.current_package = self.get_current_package()
     
    3940        self.silent          = silent
    4041        self.perf            = perf
     42        self.keep_going      = keep_going
    4143        if self.perf is not False:
    4244            f = open (self.perf, 'w+')
     
    450452      self.packages[arg['package']] ['startTime'] = time.time ()                           
    451453      status, output, error, pythonError  = exeCommand(sCmd=cmd, oLineCallback=self.redirectOutput, arg=arg)#,iTimeout = 3600)
     454      if not self.keep_going and status > 0:
     455        sys.exit(status)   
     456                     
    452457      self.packages[arg['package']] ['endTime'] = time.time ()
    453458      if self.perf:
     
    488493      print '#--------------------------------------------------------------'       
    489494      #print "# Exception occured in request #%s: %s" %(request.requestID, exc_info[1])
    490       print "# Exception occured: %s" %(exc_info[1])
     495      if exc_info[0]== exceptions.SystemExit:
     496        print "Stop execution (No_keep_going option enabled): exit code == %s " %(exc_info[1]) 
     497        print '#--------------------------------------------------------------'   
     498        sys.exit(exc_info[1])
     499      print "# Exception occured: %s" %(exc_info[1])     
    491500      print exc_info
    492501      print '#--------------------------------------------------------------'   
Note: See TracChangeset for help on using the changeset viewer.