Package Ganga :: Package Core :: Package JobRepository :: Module ARDA :: Class RemoteOracleARDAJobRepository

Class RemoteOracleARDAJobRepository

                                           object --+            
                                                    |            
                                   Base.JobRepository --+        
                                                        |        
                                      ARDARepositoryMixIn --+    
                                                            |    
Utility.external.ARDAMDClient.mdinterface.MDInterface --+   |    
                                                        |   |    
          Utility.external.ARDAMDClient.mdclient.MDClient --+    
                                                            |    
                                      RemoteARDAJobRepository --+
                                                                |
                                                               RemoteOracleARDAJobRepository

Instance Methods

[hide private]

__init__(self, schema, role, streamer, tree_streamer, root_dir, host='gangamd.cern.ch', port=8822, login='user', password='ganga', reqSSL=True, keepalive=True, init_schema=True, **kwds)
schema is a subset of job schema. source code

_isNotASequenceError(self, e)

source code

_removeAllAttributes(self, path, schema)

source code

_getBlobsFldrName(self, path)

source code

_getBlobFileName(self, fqid, guid)

source code

_initDir(self, path, schema=None, create_sequence=True)

source code

_forcedRemoveDir(self, path, schema=None, remove_sequence=True)

source code

_addBlob(self, fqid, attrs, values)

source code

_generic_addEntry(self, fqid, attrs, values)

source code

_generic_updateAttr(self, fqid, attrs, values, forced_action)

source code

_generic_eot(self)

source code

_generic_getattr(self, fqid, attr_list)

source code

_generic_getEntry(self)

source code

_generic_selectAttr(self, selection, path, attr_list)

source code

_generic_getSelectAttrEntry(self)

source code

_generic_rm(self, fqid, forced_action)

source code

Inherited from RemoteARDAJobRepository: listAllLocks, releaseAllLocks, removeAllLocks

Inherited from RemoteARDAJobRepository (private): _getGridProxy, _isDirNotFoundError

Inherited from ARDARepositoryMixIn: checkoutJobs, commitJobs, deleteJobs, getJobAttributes, getJobIds, getJobTree, getJobsStatus, registerJobs, resetAll, setJobTree, setJobsStatus

Inherited from ARDARepositoryMixIn (private): _commitJobs, _compress, _convertDbJobId, _counterNext, _createAttrIfMissing, _createDirIfMissing, _decompress, _finalizeBulkGetAttr, _finalizeBulkRm, _finalizeCommand, _fqnConverter, _generic_sequenceNext, _getCondition, _getExtendedAttrList, _getFQID, _getFQIDfromName, _getJobFileName, _getJobFolderName, _getLockedMetaData, _getMetaData, _getSelectionAndPath, _getSequenceName, _getSubJobPath, _getUpdateExpr, _getValues, _initAll, _initBulkGetAttr, _initBulkRm, _initCommand, _initCounter, _initSchema, _isDirNotEmptyError, _pstr2text, _removeAllEntries, _setLock, _setMetaData, _sortJobsByJobFolders, _text2pstr

Inherited from Base.JobRepository (private): _getJobFromStream, _getStreamFromJob

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Inherited from Utility.external.ARDAMDClient.mdclient.MDClient: abort, addAttr, addEntries, addEntry, cd, clearAttr, commit, connect, constraintAddCheck, constraintAddNotNull, constraintAddReference, constraintAddUnique, constraintDrop, constraintList, createDir, createPlainDir, disconnect, eot, execute, executeNoWait, fetchRow, find, getEntry, getSelectAttrEntry, getattr, listAttr, listEntries, put, pwd, remoteExecute, removeAttr, removeDir, replicaAdd, replicaList, replicaRegister, replicaUnregister, requireSSL, retrieveResult, rm, selectAttr, sequenceCreate, sequenceNext, sequenceRemove, setAttr, siteAdd, siteList, siteRemove, transaction, update, updateAttr, upload

Inherited from Utility.external.ARDAMDClient.mdinterface.MDInterface: splitUpdateClause

Class Variables

[hide private]

_blobsFldr = 'blobs'

_blobsFldrAttr = ('jobBlob', 'text')

Inherited from ARDARepositoryMixIn (private): _blob, _compressed, _counter, _counterName, _id, _isasubjob, _istate, _jobsTreeAttr, _jobsTreeFldr, _lock, _subjobs, _time

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, schema, role, streamer, tree_streamer, root_dir, host=`'gangamd.cern.ch'`, port=8822, login=`'user'`, password=`'ganga'`, reqSSL=True, keepalive=True, init_schema=True, **kwds)
(Constructor)

source code

schema is a subset of job schema. It should be list of tuples (attr, dbtype), where attr is a name of attribute, and dbtype is database specific type. role can be 'Client' or 'JobManager'. 'Client' can only modify job status of 'new' jobs streamer is an object which converts job dictionary into a string and vice versa. tree_streamer is an object which converts jobtree into a string and vice versa.

Overrides: Utility.external.ARDAMDClient.mdclient.MDClient.__init__

Class RemoteOracleARDAJobRepository

__init__(self, schema, role, streamer, tree_streamer, root_dir, host='gangamd.cern.ch', port=8822, login='user', password='ganga', reqSSL=True, keepalive=True, init_schema=True, **kwds) (Constructor)

_isNotASequenceError(self, e)

_removeAllAttributes(self, path, schema)

_initDir(self, path, schema=None, create_sequence=True)

_forcedRemoveDir(self, path, schema=None, remove_sequence=True)

_generic_addEntry(self, fqid, attrs, values)

_generic_updateAttr(self, fqid, attrs, values, forced_action)

_generic_eot(self)

_generic_getattr(self, fqid, attr_list)

_generic_getEntry(self)

_generic_selectAttr(self, selection, path, attr_list)

_generic_getSelectAttrEntry(self)

_generic_rm(self, fqid, forced_action)

init(self, schema, role, streamer, tree_streamer, root_dir, host=`'gangamd.cern.ch'`, port=8822, login=`'user'`, password=`'ganga'`, reqSSL=True, keepalive=True, init_schema=True, **kwds)
(Constructor)