Inheritance diagram for o2olib.O2OJobMgr:

Public Member Functions
def	__init__ (self)

def	add (self, job_name, config_filename, int_val, en_flag)

def	connect (self, service, args)

def	dumpConfig (self, jname, versionIndex, configFile)

def	listConfig (self, jname)

def	listJobs (self)

def	migrateConfig (self)

def	readConfiguration (self, config_filename)

def	runManager (self)

def	set (self, job_name, en_flag)

def	setConfig (self, job_name, config_filename)

def	setInterval (self, job_name, int_val)

Public Member Functions inherited from o2olib.O2OMgr
def	__init__ (self)

def	getSession (self, db_service, auth)

def	logger (self)

Public Attributes
	conf_dict

	db_connection

	session

	verbose

Public Attributes inherited from o2olib.O2OMgr
	eng

	logger

Detailed Description

Definition at line 139 of file o2olib.py.

Constructor & Destructor Documentation

def o2olib.O2OJobMgr.__init__ ( self )

Definition at line 141 of file o2olib.py.

     def __init__( self ):
         O2OMgr.__init__(self)
         self.db_connection = None
         self.conf_dict = {}
 
 

Member Function Documentation

def o2olib.O2OJobMgr.add	(	self,
		job_name,
		config_filename,
		int_val,
		en_flag
	)

Definition at line 175 of file o2olib.py.

References relativeConstraints.error, info(), and o2olib.O2OJobMgr.readConfiguration().

Referenced by counter.Counter.register(), SequenceTypes.Task.remove(), and SequenceTypes.Task.replace().

     def add( self, job_name, config_filename, int_val, en_flag ):
         res = self.session.query(O2OJob.enabled).filter_by(name=job_name)
         enabled = None
         for r in res:
             enabled = r
         if enabled:
             O2OMgr.logger( self).error( "A job called '%s' exists already.", job_name )
             return False
         configJson = self.readConfiguration( config_filename )
         if configJson == '':
             return False       
         job = O2OJob(name=job_name,tag_name='-',enabled=en_flag,interval=int_val)
         config = O2OJobConf( job_name=job_name, insertion_time = datetime.now(), configuration = configJson ) 
         self.session.add(job)
         self.session.add(config)
         self.session.commit()
         O2OMgr.logger( self).info( "New o2o job '%s' created.", job_name )
         return True 
 

def o2olib.O2OJobMgr.connect	(	self,
		service,
		args
	)

Definition at line 163 of file o2olib.py.

     def connect( self, service, args ):
         self.session = O2OMgr.getSession( self,service, args.auth )
         self.verbose = args.verbose
         if self.session is None:
             return False
         else:
             self.db_connection = coral_tpl %(service[0],schema_name)
             self.conf_dict['db']=self.db_connection
             return True

def o2olib.O2OJobMgr.dumpConfig	(	self,
		jname,
		versionIndex,
		configFile
	)

Definition at line 296 of file o2olib.py.

References relativeConstraints.error, createfilelist.int, edm.print(), and str.

Referenced by Types.SecSource.configValue().

     def dumpConfig( self, jname, versionIndex, configFile ):
         versionIndex = int(versionIndex)
         res = self.session.query(O2OJob.enabled).filter_by(name=jname)
         enabled = None
         for r in res:
             enabled = r
         if enabled is None:
             O2OMgr.logger( self).error( "A job called '%s' does not exist.", jname )
             return
         res = self.session.query( O2OJobConf.configuration, O2OJobConf.insertion_time  ).filter_by(job_name=jname).order_by(O2OJobConf.insertion_time)
         configs = []
         for r in res:
             configs.append((str(r[0]),r[1]))
         ind = len(configs)
         if versionIndex>ind or versionIndex==0:
             O2OMgr.logger( self ).error("Configuration for job %s with index %s has not been found." %(jname,versionIndex))
             return
         print("Configuration #%2d for job '%s'" %(versionIndex,jname))
         config = configs[versionIndex-1]
         print('#%2d  since %s' %(versionIndex,config[1]))
         print(config[0])
         if configFile is None or configFile == '':
             configFile = '%s_%s.json' %(jname,versionIndex)
         with open(configFile,'w') as json_file:
             json_file.write(config[0])
 
             

def o2olib.O2OJobMgr.listConfig	(	self,
		jname
	)

Definition at line 274 of file o2olib.py.

References relativeConstraints.error, info(), edm.print(), and str.

     def listConfig( self, jname ):
         res = self.session.query(O2OJob.enabled).filter_by(name=jname)
         enabled = None
         for r in res:
             enabled = r
         if enabled is None:
             O2OMgr.logger( self).error( "A job called '%s' does not exist.", jname )
             return
         res = self.session.query( O2OJobConf.configuration, O2OJobConf.insertion_time  ).filter_by(job_name=jname).order_by(O2OJobConf.insertion_time)
         configs = []
         for r in res:
             configs.append((str(r[0]),r[1]))
         ind = len(configs)
         if ind:
             print("Configurations for job '%s'" %jname)
             for cf in reversed(configs):
                 print('#%2d  since: %s' %(ind,cf[1]))
                 print(cf[0])
                 ind -= 1
         else:
             O2OMgr.logger( self ).info("No configuration found for job '%s'" %jname )
 

def o2olib.O2OJobMgr.listJobs ( self )

Definition at line 253 of file o2olib.py.

References Vispa.Plugins.EdmBrowser.EdmDataAccessor.all(), o2olib.print_table(), and str.

Referenced by o2olib.O2OTool.execute().

     def listJobs( self ):
         runs = {}
         res = self.session.query(O2ORun.job_name,sqlalchemy.func.max(O2ORun.start_time)).group_by(O2ORun.job_name).order_by(O2ORun.job_name)
         for r in res:
             runs[r[0]] = str(r[1])
         res = self.session.query(O2OJob.name, O2OJob.interval, O2OJob.enabled).order_by(O2OJob.name).all()
         table = []
         for r in res:
             row = []
             row.append(r[0]),
             row.append('%5d' %r[1] )
             enabled = 'Y' if (r[2]==1) else 'N'
             row.append('%4s' %enabled )
             lastRun = '-'
             if r[0] in runs.keys():
                 lastRun = runs[r[0]]
             row.append( lastRun )
             table.append(row)
         headers = ['Job name','Interval','Enabled','Last run start']
         print_table( headers, table ) 
 

def o2olib.O2OJobMgr.migrateConfig ( self )

Definition at line 239 of file o2olib.py.

References info().

     def migrateConfig( self ):
         res = self.session.query(O2OJob.name,O2OJob.tag_name)
         for r in res:
             job_name = r[0]
             tag = r[1] 
             if tag != '-':
                 configDict = {}
                 configDict['tag']=tag
                 configJson = json.dumps( configDict )
                 config = O2OJobConf( job_name=job_name, insertion_time = datetime.now(), configuration = configJson ) 
                 self.session.add(config)
                 O2OMgr.logger( self).info( "Configuration for job '%s' inserted.", job_name )
         self.session.commit()
  

def o2olib.O2OJobMgr.readConfiguration	(	self,
		config_filename
	)

Definition at line 147 of file o2olib.py.

References relativeConstraints.error.

Referenced by o2olib.O2OJobMgr.add(), and o2olib.O2OJobMgr.setConfig().

     def readConfiguration( self, config_filename ):
         config = ''
         try:
             with open( config_filename, 'r' ) as config_file:
                 config = config_file.read()
                 if config == '':
                     O2OMgr.logger( self).error( 'The file %s contains an empty string.', config_filename )
                 else:
                     json.loads(config)
         except IOError as e:
             O2OMgr.logger( self).error( 'The file %s cannot be open.', config_filename )
         except ValueError as e:
             config = ''
             O2OMgr.logger( self).error( 'The file %s contains an invalid json string.', config_filename )
         return config
 

def o2olib.O2OJobMgr.runManager ( self )

Definition at line 172 of file o2olib.py.

References o2olib.O2OJobMgr.db_connection, querying.connection.session, and o2olib.O2OJobMgr.session.

     def runManager( self ):
         return O2ORunMgr( self.db_connection, self.session, O2OMgr.logger( self ) )
 

def o2olib.O2OJobMgr.set	(	self,
		job_name,
		en_flag
	)

Definition at line 194 of file o2olib.py.

References relativeConstraints.error, and info().

     def set( self, job_name, en_flag ):
         res = self.session.query(O2OJob.enabled).filter_by(name=job_name)
         enabled = None
         for r in res:
             enabled = r
         if enabled is None:
             O2OMgr.logger( self).error( "A job called '%s' does not exist.", job_name )
             return
         job = O2OJob(name=job_name,enabled=en_flag)
         action = 'enabled'
         if not en_flag:
             action = 'disabled'
         self.session.merge(job)
         self.session.commit()
         O2OMgr.logger( self).info( "Job '%s' %s." %(job_name,action) )
 

def o2olib.O2OJobMgr.setConfig	(	self,
		job_name,
		config_filename
	)

Definition at line 210 of file o2olib.py.

References relativeConstraints.error, info(), and o2olib.O2OJobMgr.readConfiguration().

Referenced by o2olib.O2OTool.execute().

     def setConfig( self, job_name, config_filename ):
         res = self.session.query(O2OJob.enabled).filter_by(name=job_name)
         enabled = None
         for r in res:
             enabled = r
         if enabled is None:
             O2OMgr.logger( self).error( "A job called '%s' does not exist.", job_name )
             return
         configJson = self.readConfiguration( config_filename )
         if configJson == '':
             return False       
         config = O2OJobConf( job_name=job_name, insertion_time = datetime.now(), configuration = configJson ) 
         self.session.add(config)
         self.session.commit()
         O2OMgr.logger( self).info( "New configuration inserted for job '%s'", job_name )
 

def o2olib.O2OJobMgr.setInterval	(	self,
		job_name,
		int_val
	)

Definition at line 226 of file o2olib.py.

References relativeConstraints.error, and info().

Referenced by o2olib.O2OTool.execute().

     def setInterval( self, job_name, int_val ):
         res = self.session.query(O2OJob.enabled).filter_by(name=job_name)
         enabled = None
         for r in res:
             enabled = r
         if enabled is None:
             O2OMgr.logger( self).error( "A job called '%s' does not exist.", job_name )
             return
         job = O2OJob(name=job_name,interval=int_val)
         self.session.merge(job)
         self.session.commit()
         O2OMgr.logger( self).info( "The execution interval for job '%s' has been updated.", job_name )
 