Package Ganga :: Package GPIDev :: Package Lib :: Package Tasks :: Module ArgTransform :: Class ArgTransform :: Class _proxyClass
[hide private]
[frames] | no frames]

Class _proxyClass

source code

    object --+    
             |    
GPIProxyObject --+
                 |
                Lib.Tasks.ArgTransform.ArgTransform._proxyClass

Documentation missing.

Properties:

     status        Status - running, pause or completed. (simple property,
                   default='new',protected,comparable)

     name          Name of the transform (cosmetic). (simple property,
                   default='Simple Transform',comparable)

     args          A list of lists of arguments to pass to script. (simple
                   property, list, default=[],comparable)

     inputsandbox  list of File objects shipped to the worker node . ('files'
                   object, list, default=[],comparable)

     application   Application of the Transform. Must be a Task-Supporting
                   application.. ('applications' object,
                   default=None,comparable,optional)

     outputdata    Output dataset. ('datasets' object,
                   default=None,comparable,optional)

     run_limit     Number of times a partition is tried to be processed..
                   (simple property, default=4,protected,comparable)

     outputsandbox list of filenames or patterns shipped from the worker node.
                   (simple property, list, default=[],comparable)

     inputdata     Input dataset. ('datasets' object,
                   default=None,comparable,optional)

     backend       Backend of the Transform.. ('backends' object,
                   default=None,comparable,optional)

Nested Classes [hide private]
  _impl
This is a Ganga.GPI.ArgTransform implementation class.
Instance Methods [hide private]
 
__eq__(self, x)
Equality operator (==), compare the ArgTransform properties which are declared as [comparable].
source code
 
__init__(self, *args, **kwds)
GPI ArgTransform object constructor: ArgTransform() : create argtransform with default settings; ArgTransform(a) : make a copy of a; ArgTransform(a,x=a,...): make a copy of a and set property 'x' to a, etc..
source code
 
__ne__(self, x)
Non-equality operator (!=).
source code
 
__repr__(self)
Return an short representation of ArgTransform object.
source code
 
__setattr__(self, x, v)
Set a property of ArgTransform with consistency and safety checks.
source code
 
__str__(self)
Return a printable string representing ArgTransform object as a tree of properties.
source code
 
copy(self)
Make an identical copy of self.
source code
 
getJobs(...)
Get the job slice of all jobs for this transform
source code
 
getPartitionJobs(...)
Get the job slice that processed the given partition.
source code
 
getPartitionStatus(...) source code
 
info(...) source code
 
n_all(...) source code
 
n_status(...) source code
 
overview(...)
Get an ascii art overview over task status.
source code
 
pause(...)
Pause the task - the background thread will not submit new jobs from this task
source code
 
retryFailed(...)
Retry all failed partitions (forget about failed jobs)
source code
 
run(...)
Sets this transform to running status
source code
 
setFailed(...)
Tells Tasks that all Applications that have executed this partition have actually failed.
source code
 
setPartitionStatus(...)
Set the Status of the given partition to "ready", "hold", "bad" or "completed".
source code
 
setRunlimit(...)
Set the number of times a job should be resubmitted before the transform is paused
source code

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

Class Variables [hide private]
  application = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor obj...
  args = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at ...
  backend = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object ...
  inputdata = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor objec...
  inputsandbox = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor ob...
  name = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at ...
  outputdata = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor obje...
  outputsandbox = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor o...
  run_limit = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor objec...
  status = <Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object a...
Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, *args, **kwds)
(Constructor)

source code 

GPI ArgTransform object constructor: ArgTransform() : create argtransform with default settings; ArgTransform(a) : make a copy of a; ArgTransform(a,x=a,...): make a copy of a and set property 'x' to a, etc..

Overrides: object.__init__

__repr__(self)
(Representation operator)

source code 

Return an short representation of ArgTransform object.

Overrides: object.__repr__

__setattr__(self, x, v)

source code 

Set a property of ArgTransform with consistency and safety checks. Setting a [protected] or a unexisting property raises AttributeError.

Overrides: object.__setattr__

__str__(self)
(Informal representation operator)

source code 

Return a printable string representing ArgTransform object as a tree of properties.

Overrides: object.__str__

getPartitionJobs(...)

source code 

Get the job slice that processed the given partition. Iterates over the job list.

overview(...)

source code 

Get an ascii art overview over task status. Can be overridden

setPartitionStatus(...)

source code 

Set the Status of the given partition to "ready", "hold", "bad" or "completed". The status is then updated to the status indicated by the applications


Class Variable Details [hide private]

application

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a6d0>

args

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a590>

backend

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a990>

inputdata

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a910>

inputsandbox

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a610>

name

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a4d0>

outputdata

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a750>

outputsandbox

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a850>

run_limit

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a7d0>

status

Value:
<Ganga.GPIDev.Base.Proxy.ProxyDataDescriptor object at 0x1d6a410>