Warning: Can't synchronize with repository "(default)" (Unsupported version control system "svn": No module named svn). Look in the Trac log for more information.

Ticket #2472: use-logging-api-instead-of-print.patch

File use-logging-api-instead-of-print.patch, 2.0 KB (added by bochecha, 2 years ago)
  • kronos.py

     
    354354            try: 
    355355                self.sched.run() 
    356356            except Exception, err: 
    357                 print >> sys.stderr, "ERROR DURING SCHEDULER EXECUTION", err 
    358                 print >> sys.stderr, "".join( 
    359                     traceback.format_exception(*sys.exc_info())) 
    360                 print >> sys.stderr, "-" * 20 
     357                logger.error("ERROR DURING SCHEDULER EXECUTION", err) 
     358                logger.error("".join( 
     359                    traceback.format_exception(*sys.exc_info()))) 
     360                logger.error("-" * 20) 
    361361            # queue is empty; sleep a short while before checking again 
    362362            if self.running: 
    363363                time.sleep(5) 
     
    392392 
    393393    def handle_exception(self, exc): 
    394394        """ Handle any exception that occured during task execution. """ 
    395         print >> sys.stderr, "ERROR DURING TASK EXECUTION", exc 
    396         print >> sys.stderr, "".join(traceback.format_exception(*sys.exc_info())) 
    397         print >> sys.stderr, "-" * 20 
     395        logger.error("ERROR DURING TASK EXECUTION", exc) 
     396        logger.error("".join(traceback.format_exception(*sys.exc_info()))) 
     397        logger.error("-" * 20) 
    398398 
    399399 
    400400class SingleTask(Task): 
     
    645645 
    646646if __name__ == "__main__": 
    647647    def testaction(arg): 
    648         print ">>>TASK", arg, "sleeping 3 seconds" 
     648        logger.info(">>>TASK", arg, "sleeping 3 seconds") 
    649649        time.sleep(3) 
    650         print "<<<END_TASK", arg 
     650        logger.info("<<<END_TASK", arg) 
    651651 
    652652    s = ThreadedScheduler() 
    653653    s.add_interval_task( testaction, "test action 1", 0, 4, method.threaded, ["task 1"], None ) 
    654654    s.start() 
    655655     
    656     print "Scheduler started, waiting 15 sec...." 
     656    logger.info("Scheduler started, waiting 15 sec....") 
    657657    time.sleep(15) 
    658658     
    659     print "STOP SCHEDULER" 
     659    logger.info("STOP SCHEDULER") 
    660660    s.stop() 
    661661     
    662     print "EXITING" 
     662    logger.info("EXITING")