Package src :: Module pyflowTaskWrapper
[hide private]
[frames] | no frames]

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.

Classes [hide private]
  SimpleFifo
Store up to last N objects, not thread safe.
  StringBling
Functions [hide private]
 
getTracebackStr() source code
 
getExceptionMsg() source code
 
timeStampToTimeStr(ts)
converts timeStamp (time.time()) output to timeStr
source code
 
timeStrNow() source code
 
hardFlush(ofp) source code
 
isWindows() source code
 
getParams(paramsFile) source code
 
main() source code
Variables [hide private]
  scriptName = 'pyflowTaskWrapper.py'
  __package__ = 'src'