Public Member Functions
def	__init__ (self, db)

def	log (self, msg)

def	upload (self, inputTag, baseFile, destTag, synchro, destSince, success, expectedAction)

Public Attributes
	db

	errors

	logFileName

Detailed Description

Definition at line 104 of file conditionUploadTest.py.

Constructor & Destructor Documentation

◆ init()

def conditionUploadTest.UploadTest.__init__	(	self,
		db
	)

Definition at line 105 of file conditionUploadTest.py.

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

Member Function Documentation

◆ log()

def conditionUploadTest.UploadTest.log	(	self,
		msg
	)

Definition at line 110 of file conditionUploadTest.py.

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

Referenced by personalPlayback.Playback.do_create_lumi(), personalPlayback.Playback.do_exec(), personalPlayback.FrameworkJob.do_exec(), 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')
 

◆ upload()

def conditionUploadTest.UploadTest.upload	(	self,
		inputTag,
		baseFile,
		destTag,
		synchro,
		destSince,
		success,
		expectedAction
	)

Definition at line 116 of file conditionUploadTest.py.

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

     def upload( self, inputTag, baseFile, destTag, synchro, destSince, success, expectedAction ):
         insertedSince = None
         destFile = '%s.db' %destTag
         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)
         makeMetadataFile( inputTag, destTag, destSince, descr )
         beforeUpload = datetime.datetime.utcnow()
         ret = uploadFile( destFile, self.logFileName )
         if ret != success:
             self.log( 'ERROR: the return value for the upload 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.')
         os.remove( destFile )
         os.remove( metaDestFile )
         return insertedSince
 
 