Package src :: Module pyflow :: Class TaskNode

Class TaskNode

Represents an individual task in the task graph

Instance Methods

__init__(self, lock, init_id, namespace, label, payload, isContinued, isFinishedEvent, isWriteTaskStatus)
x.__init__(...) initializes x; see help(type(x)) for signature

source code

__str__(self)
str(x)

source code

fullLabel(self)

source code

isDone(self, *args, **kw)
task has gone as far as it can

source code

isError(self, *args, **kw)
true if an error occurred in this node

source code

isComplete(self, *args, **kw)
task completed without error

source code

isReady(self, *args, **kw)
task is ready to be run

source code

_isDeadWalker(self, searched)
recursive helper function for isDead()

source code

isDead(self, *args, **kw)
If true, there's no longer a point to waiting for this task, because it either has an error or there is an error in an upstream dependency

source code

setRunstate(self, *args, **kw)
updateTimeStamp is only supplied in the case where the state transition time is interestingly different than the function call time.

source code

getTaskErrorMsg(self, *args, **kw)
generate consistent task error message from task state

source code

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

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, lock, init_id, namespace, label, payload, isContinued, isFinishedEvent, isWriteTaskStatus)
(Constructor)

source code

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__: (inherited documentation)

str(self)
(Informal representation operator)

source code

str(x)

Overrides: object.__str__: (inherited documentation)

isDone(self, *args, **kw)

source code

task has gone as far as it can

Decorators:

@lockMethod

isError(self, *args, **kw)

source code

true if an error occurred in this node

Decorators:

@lockMethod

isComplete(self, *args, **kw)

source code

task completed without error

Decorators:

@lockMethod

isReady(self, *args, **kw)

source code

task is ready to be run

Decorators:

@lockMethod

isDead(self, *args, **kw)

source code

If true, there's no longer a point to waiting for this task, because it either has an error or there is an error in an upstream dependency

Decorators:

@lockMethod

setRunstate(self, *args, **kw)

source code

updateTimeStamp is only supplied in the case where the state transition time is interestingly different than the function call time. This can happen with the state update comes from a polling function with a long poll interval.

Decorators:

@lockMethod

getTaskErrorMsg(self, *args, **kw)

source code

generate consistent task error message from task state

Decorators:

@lockMethod

Class TaskNode

__init__(self, lock, init_id, namespace, label, payload, isContinued, isFinishedEvent, isWriteTaskStatus) (Constructor)

__str__(self) (Informal representation operator)

isDone(self, *args, **kw)

isError(self, *args, **kw)

isComplete(self, *args, **kw)

isReady(self, *args, **kw)

isDead(self, *args, **kw)

setRunstate(self, *args, **kw)

getTaskErrorMsg(self, *args, **kw)

init(self, lock, init_id, namespace, label, payload, isContinued, isFinishedEvent, isWriteTaskStatus)
(Constructor)

str(self)
(Informal representation operator)