Inheritance diagram for o2olib.O2ORunMgr:

Public Member Functions
def	__init__ (self, db_connection, session, logger)

def	endJob (self, status, log)

def	executeJob (self, args)

def	startJob (self, job_name)

Public Attributes
	conf_dict

	end

	job_name

	logger

	session

	start

	tag_name

Detailed Description

Definition at line 322 of file o2olib.py.

Constructor & Destructor Documentation

def o2olib.O2ORunMgr.__init__	(	self,
		db_connection,
		session,
		logger
	)

Definition at line 324 of file o2olib.py.

     def __init__( self, db_connection, session, logger ):
         self.job_name = None
         self.start = None
         self.end = None
         self.conf_dict = {}
         self.conf_dict['db'] = db_connection
         self.session = session
         self.logger = logger
 

Member Function Documentation

def o2olib.O2ORunMgr.endJob	(	self,
		status,
		log
	)

Definition at line 375 of file o2olib.py.

References poly< T >::const_iterator.end, cond::RunInfo_t.end, o2olib.O2ORunMgr.end, svgfig.LineAxis.end, o2olib.O2ORunMgr.job_name, cond::RunInfo_t.start, o2olib.O2ORunMgr.start, svgfig.LineAxis.start, and str.

Referenced by o2olib.O2ORunMgr.executeJob().

     def endJob( self, status, log ):
         self.end = datetime.now()
         try:
             run = O2ORun(job_name=self.job_name,start_time=self.start,end_time=self.end,status_code=status,log=log)
             self.session.merge(run)
             self.session.commit()
             self.logger.info( 'Job %s ended.', self.job_name )
             return 0
         except sqlalchemy.exc.SQLAlchemyError as dberror:
             self.logger.error( str(dberror) )
             return 8
 

def o2olib.O2ORunMgr.executeJob	(	self,
		args
	)

Definition at line 387 of file o2olib.py.

     def executeJob( self, args ):
         job_name = args.name
         command = args.executable
         logFolder = os.getcwd()
         if logFolderEnvVar in os.environ:
             logFolder = os.environ[logFolderEnvVar]
         datelabel = datetime.now().strftime("%y-%m-%d-%H-%M-%S")
         logFileName = '%s-%s.log' %(job_name,datelabel)
         logFile = os.path.join(logFolder,logFileName)
         started = self.startJob( job_name )
         if started !=0:
             return started
         ret = -1
         try:
             # replacing %([key])s placeholders... 
             command = command %(self.conf_dict)
             #replacing {[key]} placeholders
             command = command.format(**self.conf_dict )
         except KeyError as exc:
             self.logger.error( "Unresolved template key %s in the command." %str(exc) )
             return 3
         self.logger.info('Command: "%s"', command )
         try:
             self.logger.info('Executing command...' )
             pipe = subprocess.Popen( command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT )
             out = ''
             for line in iter(pipe.stdout.readline, ''):
                 if args.verbose>=1:
                     sys.stdout.write(line)
                     sys.stdout.flush()
                 out += line
             pipe.communicate()
             self.logger.info( 'Command returned code: %s' %pipe.returncode )
             ret = pipe.returncode
         except Exception as e:
             self.logger.error( str(e) )
             return 4
         ended = self.endJob( pipe.returncode, out )
         if ended != 0:
             ret = ended
         with open(logFile,'a') as logF:
             logF.write(out)
         return ret

def o2olib.O2ORunMgr.startJob	(	self,
		job_name
	)

Definition at line 333 of file o2olib.py.

References createfilelist.int.

Referenced by o2olib.O2ORunMgr.executeJob().

     def startJob( self, job_name ):
         self.logger.info('Checking job %s', job_name)
         exists = None
         enabled = None
         try:
             res = self.session.query(O2OJob.enabled,O2OJob.tag_name).filter_by(name=job_name)
             for r in res:
                 exists = True
                 enabled = int(r[0])
                 self.tag_name = str(r[1]) 
             if exists is None:
                 self.logger.error( 'The job %s is unknown.', job_name )
                 return 2
             if enabled:
                 res = self.session.query(O2OJobConf.configuration).filter_by(job_name=job_name).order_by(sqlalchemy.desc(O2OJobConf.insertion_time)).first()
                 conf = None
                 for r in res:
                     conf = str(r)
                 if conf is None:
                     self.logger.warning("No configuration found for job '%s'" %job_name )
                 else:
                     try:
                         self.conf_dict.update( json.loads(conf) )
                         self.logger.info('Using configuration: %s ' %conf)
                     except Exception as e:
                         self.logger.error( str(e) )
                         return 6
                 self.job_name = job_name
                 self.start = datetime.now()
                 run = O2ORun(job_name=self.job_name,start_time=self.start,status_code=startStatus)
                 self.session.add(run)
                 self.session.commit()
                 return 0
             else:
                 self.logger.info( 'The job %s has been disabled.', job_name )
                 return 5
         except sqlalchemy.exc.SQLAlchemyError as dberror:
                 self.logger.error( str(dberror) )
                 return 7
         return -1
 
 