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

Class LocalARDAJobRepository

                                           object --+        
                                                    |        
                                   Base.JobRepository --+    
                                                        |    
                                      ARDARepositoryMixIn --+
                                                            |
Utility.external.ARDAMDClient.mdinterface.MDInterface --+   |
                                                        |   |
  Utility.external.ARDAMDClient.mdstandalone.MDStandalone --+
                                                            |
                                                           LocalARDAJobRepository

Instance Methods

[hide private]

__init__(self, schema, role, streamer, tree_streamer, root_dir, local_root='/tmp/', blocklength=1000, cache_size=100000, tries_limit=200, lock_timeout=1, init_schema=True, **kwds)
schema is a subset of job schema. source code

_createDirIfMissing(self, path)

source code

_createAttrIfMissing(self, path, schema)

source code

_get_iteration_list(self, mdtable)

source code

_generic_selectAttr(self, selection, path, attr_list)

source code

_generic_getattr(self, fqid, attrs)

source code

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

source code

_generic_rm(self, fqid, forced_action)

source code

_generic_sequenceNext(self, name, reserve=0)

source code

_initBulkGetAttr(self)

source code

_finalizeBulkGetAttr(self)

source code

_initBulkRm(self)

source code

_finalizeBulkRm(self)

source code

removeAllLocks(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, _decompress, _finalizeCommand, _forcedRemoveDir, _fqnConverter, _generic_addEntry, _generic_eot, _generic_getEntry, _generic_getSelectAttrEntry, _getCondition, _getExtendedAttrList, _getFQID, _getFQIDfromName, _getJobFileName, _getJobFolderName, _getLockedMetaData, _getMetaData, _getSelectionAndPath, _getSequenceName, _getSubJobPath, _getUpdateExpr, _getValues, _initAll, _initCommand, _initCounter, _initDir, _initSchema, _isDirNotEmptyError, _isDirNotFoundError, _isNotASequenceError, _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.mdstandalone.MDStandalone: abort, addAttr, addEntries, addEntry, cd, commit, createDir, eot, getEntry, getSelectAttrEntry, getattr, listAttr, listEntries, put, pwd, releaseAllLocks, removeAttr, removeDir, rm, selectAttr, sequenceCreate, sequenceNext, sequenceRemove, setAttr, transaction, updateAttr, upload

Inherited from Utility.external.ARDAMDClient.mdinterface.MDInterface: clearAttr, 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, local_root=`'/tmp/'`, blocklength=1000, cache_size=100000, tries_limit=200, lock_timeout=1, 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.mdstandalone.MDStandalone.__init__

Class LocalARDAJobRepository

__init__(self, schema, role, streamer, tree_streamer, root_dir, local_root='/tmp/', blocklength=1000, cache_size=100000, tries_limit=200, lock_timeout=1, init_schema=True, **kwds) (Constructor)

_createDirIfMissing(self, path)

_createAttrIfMissing(self, path, schema)

_generic_selectAttr(self, selection, path, attr_list)

_generic_getattr(self, fqid, attrs)

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

_generic_rm(self, fqid, forced_action)

_generic_sequenceNext(self, name, reserve=0)

_initBulkGetAttr(self)

_finalizeBulkGetAttr(self)

_initBulkRm(self)

_finalizeBulkRm(self)

removeAllLocks(self)

listAllLocks(self)

init(self, schema, role, streamer, tree_streamer, root_dir, local_root=`'/tmp/'`, blocklength=1000, cache_size=100000, tries_limit=200, lock_timeout=1, init_schema=True, **kwds)
(Constructor)