Package src :: Module pyflow :: Class WorkflowRunnerThreadSharedData

Class WorkflowRunnerThreadSharedData

All data used by the WorkflowRunner which will be constant over the lifetime of a TaskManager instance. All of the information in this class will be accessed by both threads without locking.

Instance Methods

[hide private]

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

source code

_setCustomLogs(self)

source code

setupNewRun(self, param)

source code

resetRun(self)
Anything that needs to be cleaned up at the end of a run

source code

getRunid(self)

source code

setTaskError(self, *args, **kw)

source code

isTaskError(self, *args, **kw)

source code

isTaskSubmissionActive(self)
wait() pollers need to know if task submission has been shutdown to implement sane behavior.

source code

setTaskManagerException(self, *args, **kw)

source code

flowLog(self, *args, **kw)

source code

getInfoMsg(self)
return a string array with general stats about this run

source code

emailNotification(self, msgList, emailErrorLog=None)

source code

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