Module pyflowTaskWrapper
source code
This script wraps workflow tasks for execution on local or remote
hosts. It is responsible for adding log decorations to task's stderr
output (which is diverted to a file), and writing task state transition
and error information to the wrapper's stderr, which becomes the task's
'signal' file from pyflow's perspective. The signal file is used to
determine task exit status, total runtime, and queue->run state
transition when pyflow is run in SGE mode.
|
|
|
|
|
timeStampToTimeStr(ts)
converts timeStamp (time.time()) output to timeStr |
source code
|
|
|
|
|
|
|
|
|
|
|
|
|
scriptName = ' pyflowTaskWrapper.py '
|
|
__package__ = ' src '
|