o2olib.O2OMgr Class Reference

Inheritance diagram for o2olib.O2OMgr:

Public Member Functions
def	__init__ (self)
def	getSession (self, db_service, auth)
def	logger (self)

Public Attributes
	eng
	logger

Detailed Description

Definition at line 98 of file o2olib.py.

Constructor & Destructor Documentation

__init__()

def o2olib.O2OMgr.__init__

(

self

)

Reimplemented in o2olib.O2OJobMgr.

Definition at line 99 of file o2olib.py.

    def __init__(self):
        self.logger = logging.getLogger()        
        self.logger.setLevel(logLevel)
        consoleHandler = logging.StreamHandler(sys.stdout) 
        consoleHandler.setFormatter(logFormatter)
        self.logger.addHandler(consoleHandler)
        self.eng = None
 

Member Function Documentation

getSession()

def o2olib.O2OMgr.getSession	(		self,
			db_service,
			auth
	)

Definition at line 110 of file o2olib.py.

    def getSession( self, db_service, auth ):
        url = None
        if db_service is None:
            url = private_db
        else:
            self.logger.info('Getting credentials')
            if auth is not None:
                if not os.path.exists(auth):
                    self.logger.error('Authentication path %s is invalid.' %auth)
                    return None
            try:
                username, pwd = get_db_credentials( db_service, auth )
            except Exception as e:
                logging.debug(str(e))
                username = None
                pwd = None
            if username is None:
                logging.error('Credentials for service %s (machine=%s) are not available' %(db_service[0],db_service[1]))
                raise Exception("Cannot connect to db %s" %db_service[0] )
            url = sqlalchemy_tpl %(username,pwd,db_service[0])
        session = None
        try:
            self.eng = sqlalchemy.create_engine( url )
            session = sqlalchemy.orm.scoped_session( sqlalchemy.orm.sessionmaker(bind=self.eng))
        except sqlalchemy.exc.SQLAlchemyError as dberror:
            self.logger.error( str(dberror) )
        return session
 

References o2olib.O2OMgr.eng, relativeConstraints.error, o2olib.get_db_credentials(), info(), crabFunctions.CrabController.logger, o2olib.O2OMgr.logger, and str.

logger()

def o2olib.O2OMgr.logger

(

self

)

Definition at line 107 of file o2olib.py.

    def logger( self ):
        return self.logger
        

References crabFunctions.CrabController.logger, and o2olib.O2OMgr.logger.

Member Data Documentation

eng

o2olib.O2OMgr.eng

Definition at line 105 of file o2olib.py.

Referenced by o2olib.O2OMgr.getSession().

logger

o2olib.O2OMgr.logger

Definition at line 100 of file o2olib.py.

Referenced by o2olib.O2ORunMgr.endJob(), o2olib.O2ORunMgr.executeJob(), o2olib.O2OMgr.getSession(), o2olib.O2OMgr.logger(), looper.Looper.loop(), cmsHarvester.CMSHarvester.option_handler_book_keeping_file(), cmsHarvester.CMSHarvester.option_handler_debug(), cmsHarvester.CMSHarvester.option_handler_force(), cmsHarvester.CMSHarvester.option_handler_frontier_connection(), cmsHarvester.CMSHarvester.option_handler_globaltag(), cmsHarvester.CMSHarvester.option_handler_harvesting_mode(), cmsHarvester.CMSHarvester.option_handler_harvesting_type(), cmsHarvester.CMSHarvester.option_handler_input_spec(), cmsHarvester.CMSHarvester.option_handler_no_ref_hists(), cmsHarvester.CMSHarvester.option_handler_ref_hist_mapping_file(), and o2olib.O2ORunMgr.startJob().