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

Class RemoteARDAJobRepository

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

Known Subclasses:

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

_getGridProxy(self)

source code

_isDirNotFoundError(self, e)

source code

_isNotASequenceError(self, e)

source code

removeAllLocks(self)

source code

releaseAllLocks(self)

source code

listAllLocks(self)

source code

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, _forcedRemoveDir, _fqnConverter, _generic_addEntry, _generic_eot, _generic_getEntry, _generic_getSelectAttrEntry, _generic_getattr, _generic_rm, _generic_selectAttr, _generic_sequenceNext, _generic_updateAttr, _getCondition, _getExtendedAttrList, _getFQID, _getFQIDfromName, _getJobFileName, _getJobFolderName, _getLockedMetaData, _getMetaData, _getSelectionAndPath, _getSequenceName, _getSubJobPath, _getUpdateExpr, _getValues, _initAll, _initBulkGetAttr, _initBulkRm, _initCommand, _initCounter, _initDir, _initSchema, _isDirNotEmptyError, _pstr2text, _removeAllAttributes, _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]

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__

_isDirNotFoundError(self, e)

source code

Overrides: ARDARepositoryMixIn._isDirNotFoundError

_isNotASequenceError(self, e)

source code

Overrides: ARDARepositoryMixIn._isNotASequenceError

Class RemoteARDAJobRepository

__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)

_isDirNotFoundError(self, e)

_isNotASequenceError(self, e)

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)