Package Ganga :: Package GPIDev :: Package Lib :: Package Tasks :: Module ArgTransform :: Class ArgTransform

Class ArgTransform

          object --+            
                   |            
   Base.Objects.Node --+        
                       |        
Base.Objects.GangaObject --+    
                           |    
        Transform'.Transform --+
                               |
                              ArgTransform

This is a Ganga.GPI.ArgTransform implementation class. Refer to Ganga.GPI.ArgTransform.__doc__ for documentation.

Nested Classes

[hide private]

_proxyClass
Documentation missing.

Inherited from Base.Objects.GangaObject: __metaclass__

Instance Methods

[hide private]

_checksetNestedLists(self, value)
The rule is that if there are nested lists then they must not contain GangaObjects, as this corrupts the repository

source code

check(self)

source code

getJobsForPartitions(self, partitions)
Create Ganga Jobs for the next N partitions that are ready and submit them.

source code

Inherited from Transform'.Transform: __init__, checkCompletedApp, checkTaskApplication, createNewJob, finalise, fix, fqn, getJobs, getNewAppID, getNextPartitions, getPartitionApps, getPartitionFailures, getPartitionJobs, getPartitionStatus, info, initialize, n_all, n_status, notifyNextTransform, overview, pause, retryFailed, run, setAppStatus, setFailed, setPartitionStatus, setPartitionsLimit, setPartitionsStatus, setRunlimit, startup, submitJobs, updateInputStatus, updatePartitionStatus, updateStatus

Inherited from Transform'.Transform (private): _readonly

Inherited from Base.Objects.GangaObject: __construct__, __deepcopy__, __getstate__, __setstate__, _attribute_filter__set__, _auto__init__, accept, getJobObject

Inherited from Base.Objects.GangaObject (private): _getReadAccess, _getRegistry, _getRegistryID, _getWriteAccess, _releaseWriteAccess, _setDirty, _setFlushed, _setRegistry

Inherited from Base.Objects.Node: __copy__, __eq__, __ne__, clone, copyFrom, printSummaryTree, printTree

Inherited from Base.Objects.Node (private): _getParent, _getRoot, _setParent

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

Class Methods

[hide private]

Inherited from Base.Objects.GangaObject (private): _declared_property

Class Variables

[hide private]

_schema = Schema(Version(1, 0), dict(Transform._schema.datadic...

_category = 'transforms'

_name = 'ArgTransform'

_exportmethods = Transform._exportmethods

_app_partition = <Ganga.GPIDev.Base.Objects.Descriptor object ...

_app_status = <Ganga.GPIDev.Base.Objects.Descriptor object at ...

_next_app_id = <Ganga.GPIDev.Base.Objects.Descriptor object at...

_partition_status = <Ganga.GPIDev.Base.Objects.Descriptor obje...

application = <Ganga.GPIDev.Base.Objects.Descriptor object at ...

args = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a550>

backend = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d...

inputdata = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x...

inputsandbox = <Ganga.GPIDev.Base.Objects.Descriptor object at...

name = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a490>

outputdata = <Ganga.GPIDev.Base.Objects.Descriptor object at 0...

outputsandbox = <Ganga.GPIDev.Base.Objects.Descriptor object a...

run_limit = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x...

status = <Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6...

Inherited from Transform'.Transform (private): _partition_apps

Inherited from Base.Objects.GangaObject (private): _hidden, _registry

Inherited from Base.Objects.Node (private): _index_cache, _parent

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

check(self)

source code

Overrides: Transform'.Transform.check

getJobsForPartitions(self, partitions)

source code

Create Ganga Jobs for the next N partitions that are ready and submit them.

Overrides: Transform'.Transform.getJobsForPartitions

Class Variable Details

[hide private]

_schema

Value:

Schema(Version(1, 0), dict(Transform._schema.datadict.items()+ {'args'
: SimpleItem(defvalue= [], typelist= ['list', 'Ganga.GPIDev.Lib.GangaL
ist.GangaList.GangaList'], sequence= 1, checkset= '_checksetNestedList
s', doc= 'A list of lists of arguments to pass to script'),}.items()))

_app_partition

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a510>

_app_status

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a890>

_next_app_id

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a450>

_partition_status

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a650>

application

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a690>

backend

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a950>

inputdata

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a8d0>

inputsandbox

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a5d0>

outputdata

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a710>

outputsandbox

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a810>

run_limit

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a790>

status

Value:

<Ganga.GPIDev.Base.Objects.Descriptor object at 0x1d6a3d0>