Public Member Functions
def	__init__ (self, db)

def	execute (self, sourceTag, baseFile, destTag, synchro, destSince, success, expectedAction)

def	log (self, msg)

Public Attributes
	db

	errors

	logFileName

Detailed Description

Definition at line 47 of file conddbCopyTest.py.

Constructor & Destructor Documentation

◆ init()

def conddbCopyTest.CopyTest.__init__	(	self,
		db
	)

Definition at line 48 of file conddbCopyTest.py.

     def __init__(self, db):
         self.db = db
         self.errors = 0
         self.logFileName = 'conddbCopyTest.log'
 

Member Function Documentation

◆ execute()

def conddbCopyTest.CopyTest.execute	(	self,
		sourceTag,
		baseFile,
		destTag,
		synchro,
		destSince,
		success,
		expectedAction
	)

Definition at line 59 of file conddbCopyTest.py.

References conddbCopyTest.copy(), Histograms_PPSDiamondSampicTimingCalibrationPCLWorker.db, conddbCopyTest.CopyTest.db, conddb_version_mgr.version_db.db, conddb_version_mgr.conddb_tool.db, HcalLutManager.db, conddbCopyTest.CopyTest.errors, conddbCopyTest.CopyTest.log(), cond::persistency::Logger.log(), cond::CredentialStore.log(), crabFunctions.CrabTask.log, and conddbCopyTest.CopyTest.logFileName.

     def execute( self, sourceTag, baseFile, destTag, synchro, destSince, success, expectedAction ):
         insertedSince = None
         metaDestFile = '%s.txt' %destTag
         #shutil.copyfile( baseFile, destFile )
         self.log( '# ---------------------------------------------------------------------------')
         self.log( '# Testing tag %s with synch=%s, destSince=%s - expecting ret=%s action=%s' %(destTag,synchro,destSince,success,expectedAction))
     
         descr = 'Testing conditionsUpload with synch:%s - expected action: %s' %(synchro,expectedAction)
         beforeUpload = datetime.datetime.utcnow()
         ret = copy( sourceTag, destTag, destSince, self.logFileName )
         if ret != success:
             self.log( 'ERROR: the return value for the copy of tag %s with sychro %s was %s, while the expected result is %s' %(destTag,synchro,ret,success))
             self.errors += 1
         else:
             row = self.db.getLastInsertedSince( destTag, beforeUpload )
             if ret == True:
                 if expectedAction == 'CREATE' or expectedAction == 'INSERT' or expectedAction == 'APPEND':
                     if destSince != row[0]:
                         self.log( 'ERROR: the since inserted is %s, expected value is %s - expected action: %s' %(row[0],destSince,expectedAction))
                         self.errors += 1
                     else:
                         self.log( '# OK: Found expected value for last since inserted: %s timestamp: %s' %(row[0],row[1]))
                         insertedSince = row[0]
                 elif expectedAction == 'SYNCHRONIZE':
                     if destSince == row[0]:
                         self.log( 'ERROR: the since inserted %s has not been synchronized with the FCSR - expected action: %s' %(row[0],expectedAction))
                         self.errors += 1
                     else:
                         self.log( '# OK: Found synchronized value for the last since inserted: %s timestamp: %s' %(row[0],row[1]))
                         insertedSince = row[0]
                 else:
                     self.log( 'ERROR: found an appended since %s - expected action: %s' %(row[0],expectedAction))
                     self.errors += 1
             else:
                 if not row is None:
                     self.log( 'ERROR: found new insered since: %s timestamp: %s' %(row[0],row[1]))
                     self.errors += 1
                 if expectedAction != 'FAIL':
                     self.log( 'ERROR: Upload failed. Expected value: %s' %(destSince))
                     self.errors += 1
                 else:
                     self.log( '# OK: Upload failed as expected.')
         return insertedSince
 
 

◆ log()

def conddbCopyTest.CopyTest.log	(	self,
		msg
	)

Definition at line 53 of file conddbCopyTest.py.

References conddbCopyTest.CopyTest.logFileName, and print().

Referenced by personalPlayback.Playback.do_create_lumi(), personalPlayback.Playback.do_exec(), personalPlayback.FrameworkJob.do_exec(), conddbCopyTest.CopyTest.execute(), personalPlayback.FrameworkJob.start_run(), and conditionUploadTest.UploadTest.upload().

     def log( self, msg ):
         print(msg)
         with open(self.logFileName,'a') as logFile:
             logFile.write(msg)
             logFile.write('\n')
 