conditionUploadTest.UploadTest Class Reference

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

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

def conditionUploadTest.UploadTest.log	(		self,
			msg
	)

Definition at line 110 of file conditionUploadTest.py.

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

Referenced by conditionUploadTest.UploadTest.upload().

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

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

Definition at line 116 of file conditionUploadTest.py.

References conddbCopyTest.CopyTest.errors, conditionUploadTest.UploadTest.errors, conddbCopyTest.CopyTest.log(), conditionUploadTest.UploadTest.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

Member Data Documentation

conditionUploadTest.UploadTest.db

Definition at line 106 of file conditionUploadTest.py.

conditionUploadTest.UploadTest.errors

Definition at line 107 of file conditionUploadTest.py.

Referenced by conditionUploadTest.UploadTest.upload().

conditionUploadTest.UploadTest.logFileName

Definition at line 108 of file conditionUploadTest.py.

Referenced by conditionUploadTest.UploadTest.log(), and conditionUploadTest.UploadTest.upload().