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)
|
_impl
This is a Ganga.GPI.ArgTransform implementation class.
|
|
__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
|
|
|
|
|
|
|
__str__(self)
Return a printable string representing ArgTransform object as a tree
of properties. |
source code
|
|
|
|
|
getJobs(...)
Get the job slice of all jobs for this transform |
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
|
|
|
|
|
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__
|
|
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...
|
Inherited from object :
__class__
|
__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__
|
Return an short representation of ArgTransform object.
- Overrides:
object.__repr__
|
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__
|
Get the job slice that processed the given partition. Iterates over
the job list.
|
Get an ascii art overview over task status. Can be overridden
|
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
|
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>
|
|