Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

add() (in SimpleFifo)	addTask() (in WorkflowRunner)	allowed_modes (in RetryParam)
addTask() (in TaskDAG)	addWorkflowTask() (in WorkflowRunner)	argToBool() (in src.pyflow)

B

BaseTaskRunner (in src.pyflow)	boolToStr() (in src.pyflow)	Bunch (in src.pyflow)

C

cachedHostName (in src.pyflowConfig)	cleanStr() (in Command)	CommandTaskRunner (in src.pyflow)
cancelTaskTree() (in TaskManager)	cmdline() (in src.pyflow)	count() (in SimpleFifo)
cancelTaskTree() (in WorkflowRunner)	CmdPayload (in src.pyflow)
cleanEnv() (in src.pyflow)	Command (in src.pyflow)

D

data (in RunMode)	DefaultSiteConfig (in src.pyflowConfig)	desc() (in WorkflowPayload)
DataDirException (in src.pyflow)	defaultTaskMemMb (in DefaultSiteConfig)	DotConfig (in src.pyflow)
defaultHostMemMbPerCore (in DefaultSiteConfig)	desc() (in CmdPayload)

E

emailNotification() (in WorkflowRunnerThreadSharedData)	ensureDir() (in src.pyflow)	ExpWaiter (in src.pyflow)
emailRegex (in src)	ERROR (in LogState)
emailRegex (in src.pyflow)	errorLog() (in BaseTaskRunner)

F

flowLog() (in BaseTaskRunner)	flowLog() (in WorkflowRunnerThreadSharedData)	forceRename() (in src.pyflow)
flowLog() (in WorkflowRunner)	flush() (in TaskFileWriter)	fullLabel() (in TaskNode)

G

get() (in SimpleFifo)	getInfoMsg() (in WorkflowRunnerThreadSharedData)	getTaskCopy() (in RetryParam)
getAllNodes() (in TaskDAG)	getMemMb() (in WorkflowRunner)	getTaskErrorMsg() (in TaskNode)
getDomainName() (in DefaultSiteConfig)	getNCores() (in WorkflowRunner)	getTaskInfoDepSet() (in src.pyflow)
getDomainName() (in src.pyflowConfig)	getParams() (in src.pyflowTaskWrapper)	getTaskStatus() (in TaskDAG)
getDotLegend() (in DotConfig)	getPyflowVersion() (in src.pyflow)	getThreadName() (in src.pyflow)
getEnvVar() (in src.pyflowConfig)	getPythonVersion() (in src.pyflow)	getTracebackStr() (in src.pyflow)
getExceptionMsg() (in src.pyflow)	getReadyTasks() (in TaskDAG)	getTracebackStr() (in src.pyflowTaskWrapper)
getExceptionMsg() (in src.pyflowTaskWrapper)	getRunid() (in WorkflowRunnerThreadSharedData)	getTypeDotAttrib() (in DotConfig)
getExitMsg() (in CommandTaskRunner)	getRunMode() (in WorkflowRunner)	getWrapFileResult() (in CommandTaskRunner)
getFullCmd() (in LocalTaskRunner)	getRunstateDotAttrib() (in DotConfig)	getWrapperErrorMsg() (in CommandTaskRunner)
getFullCmd() (in SGETaskRunner)	getSGEJobsDefault() (in src.pyflow)	GlobalConstants (in src.pyflow)
getHeadNodes() (in TaskDAG)	getSgeMakePrefix() (in DefaultSiteConfig)	GlobalSync (in src.pyflow)
getHostName() (in DefaultSiteConfig)	getTailNodes() (in TaskDAG)
getHostName() (in src.pyflowConfig)	getTask() (in TaskDAG)

H

hardFlush() (in src.pyflow)	harvestTasks() (in TaskManager)	hvmemSGEConfig (in src.pyflowConfig)
hardFlush() (in src.pyflowTaskWrapper)	hashObjectValue() (in src.pyflow)

I

INFO (in LogState)	isInt() (in src.pyflow)	isTaskDone() (in WorkflowRunner)
infoLog() (in BaseTaskRunner)	isIterable() (in src.pyflow)	isTaskError() (in WorkflowRunnerThreadSharedData)
initFileSystemItems() (in CommandTaskRunner)	isLocalSmtp() (in src.pyflow)	isTaskPresent() (in TaskDAG)
isComplete() (in TaskNode)	isMainThread() (in src.pyflow)	isTaskSubmissionActive() (in WorkflowRunnerThreadSharedData)
isDead() (in TaskNode)	isReady() (in TaskNode)	isWindows (in GlobalConstants)
isDone() (in TaskNode)	isRunComplete() (in TaskDAG)	isWindows() (in src.pyflow)
isDryRun() (in WorkflowRunner)	isRunExhausted() (in TaskDAG)	isWindows() (in src.pyflowTaskWrapper)
isError() (in TaskNode)	isString() (in src.pyflow)
isFsync (in LogGlobals)	isTaskComplete() (in WorkflowRunner)

K

killProc() (in QCaller)

L

limitMemMb() (in WorkflowRunner)	LocalTaskRunner (in src.pyflow)	LogGlobals (in src.pyflow)
limitNCores() (in WorkflowRunner)	lockMethod() (in src.pyflow)	LogState (in src.pyflow)
lister() (in src.pyflow)	log() (in src.pyflow)

M

mailFrom (in DefaultSiteConfig)	maxSGEJobs (in DefaultSiteConfig)	moduleDir (in src)
main() (in src.pyflowTaskWrapper)	maxSubprocess (in GlobalSync)	moduleDir (in src.pyflow)
markCheckPointsComplete() (in TaskDAG)	ModeInfo (in src.pyflow)	msgListToMsg() (in src.pyflow)

N

name() (in WorkflowPayload)	namespaceLabel() (in src.pyflow)	namespaceSep (in src.pyflow)
namespaceJoin() (in src.pyflow)	namespaceSep (in src)

P

pyflow (in src)	pythonVersion (in src.pyflow)	pyver (in src)
pyflowConfig (in src)	pythonVersion (in src)
pyflowTaskWrapper (in src)	pyver (in src.pyflow)

Q

QCaller (in src.pyflow)	qsubResourceArg() (in DefaultSiteConfig)

R

reset() (in ExpWaiter)	run() (in TaskFileWriter)	RunningTaskStatus (in src.pyflow)
resetRun() (in WorkflowRunnerThreadSharedData)	run() (in TaskManager)	runOnce() (in LocalTaskRunner)
RetryParam (in src.pyflow)	run() (in WorkflowRunner)	runOnce() (in SGETaskRunner)
run() (in BaseTaskRunner)	RunMode (in src.pyflow)	runstateDotColor (in DotConfig)
run() (in QCaller)	runModeDefaultCores() (in WorkflowRunner)	runstateDotStyle (in DotConfig)

S

scriptName (in src.pyflowTaskWrapper)	setupNewRun() (in WorkflowRunnerThreadSharedData)	stop() (in TaskManager)
sendEmail() (in src.pyflow)	setzer() (in src.pyflow)	stopAll() (in StoppableThread)
setInitialRunstate() (in BaseTaskRunner)	SGETaskRunner (in src.pyflow)	StoppableThread (in src.pyflow)
setInitialRunstate() (in SGETaskRunner)	SimpleFifo (in src.pyflowTaskWrapper)	stopped() (in StoppableThread)
setNewJobId() (in SGETaskRunner)	siteConfigFactory() (in src.pyflowConfig)	StrFileObject (in src.pyflow)
setRunstate() (in BaseTaskRunner)	src	StringBling (in src.pyflowTaskWrapper)
setRunstate() (in TaskNode)	stackDump() (in src.pyflow)	subprocessControl (in GlobalSync)
setTaskError() (in WorkflowRunnerThreadSharedData)	stop() (in SGETaskRunner)
setTaskManagerException() (in WorkflowRunnerThreadSharedData)	stop() (in StoppableThread)

T

TaskDAG (in src.pyflow)	taskStateHeader() (in src.pyflow)	timeStrToTimeStamp() (in src.pyflow)
TaskFileWriter (in src.pyflow)	taskStateParser() (in src.pyflow)	toString() (in LogState)
taskInfoHeader() (in src.pyflow)	taskWrapper (in CommandTaskRunner)	transfer() (in StringBling)
taskInfoParser() (in src.pyflow)	timeStampToTimeStr() (in src.pyflow)	type() (in CmdPayload)
TaskManager (in src.pyflow)	timeStampToTimeStr() (in src.pyflowTaskWrapper)	type() (in WorkflowPayload)
TaskNode (in src.pyflow)	timeStrNow() (in src.pyflow)
TaskNodeConstants (in src.pyflow)	timeStrNow() (in src.pyflowTaskWrapper)

V

validate() (in RetryParam)	validRunstates (in TaskNodeConstants)	verifyEmailAddy() (in src.pyflow)

W

wait() (in ExpWaiter)	WorkflowPayload (in src.pyflow)	write() (in StrFileObject)
waitForTasks() (in WorkflowRunner)	WorkflowRunner (in src.pyflow)	writeDotGraph() (in src.pyflow)
WARNING (in LogState)	WorkflowRunnerThreadSharedData (in src.pyflow)	writeDotScript() (in src.pyflow)
warningLog() (in BaseTaskRunner)	WorkflowTaskRunner (in src.pyflow)	writeTaskInfo() (in TaskDAG)
workflow() (in WorkflowRunner)	wrapperLog() (in StringBling)	writeTaskStatus() (in TaskDAG)

_

__init__() (in BaseTaskRunner)	_allStop (in WorkflowRunner)	_isWindows() (in src.pyflow)
__init__() (in Bunch)	_appendNamespace() (in WorkflowRunner)	_isWorkflowStopped() (in WorkflowRunner)
__init__() (in CmdPayload)	_areTasksDead() (in TaskManager)	_killJob() (in SGETaskRunner)
__init__() (in Command)	_cancelTaskTreeCore() (in WorkflowRunner)	_killWorkflow() (in WorkflowRunner)
__init__() (in CommandTaskRunner)	_cdata() (in WorkflowRunner)	_launchTask() (in TaskManager)
__init__() (in DataDirException)	_checkTaskLabel() (in WorkflowRunner)	_markCheckPointsCompleteFromNode() (in TaskDAG)
__init__() (in ExpWaiter)	_createContinuedInfoFile() (in WorkflowRunner)	_maxWorkflowRecursion (in WorkflowRunner)
__init__() (in ModeInfo)	_createContinuedStateFile() (in WorkflowRunner)	_notify() (in WorkflowRunner)
__init__() (in QCaller)	_errorLog() (in TaskManager)	_qsubResourceArgConfig() (in DefaultSiteConfig)
__init__() (in RetryParam)	_errorLog() (in WorkflowRunner)	_qsubResourceArgConfig() (in hvmemSGEConfig)
__init__() (in RunningTaskStatus)	_evalWorkflow() (in WorkflowRunner)	_removeTaskFromRunningSet() (in TaskManager)
__init__() (in StoppableThread)	_finalize() (in RetryParam)	_requireInWorkflow() (in WorkflowRunner)
__init__() (in StrFileObject)	_flowLog() (in TaskManager)	_run() (in CommandTaskRunner)
__init__() (in TaskDAG)	_flowLog() (in WorkflowRunner)	_run() (in WorkflowTaskRunner)
__init__() (in TaskFileWriter)	_getCommandTaskRunner() (in TaskManager)	_runUpdate() (in WorkflowRunner)
__init__() (in TaskManager)	_getHostName() (in src.pyflowConfig)	_runWorkflow() (in WorkflowRunner)
__init__() (in TaskNode)	_getNamespace() (in WorkflowRunner)	_setCustomLogs() (in WorkflowRunnerThreadSharedData)
__init__() (in WorkflowPayload)	_getNamespaceList() (in WorkflowRunner)	_setRunning() (in WorkflowRunner)
__init__() (in WorkflowRunnerThreadSharedData)	_getReadyTasksFromNode() (in TaskDAG)	_setupContinuedWorkflow() (in WorkflowRunner)
__init__() (in WorkflowTaskRunner)	_getRunning() (in WorkflowRunner)	_setupWorkflow() (in WorkflowRunner)
__init__() (in SimpleFifo)	_getTaskErrorsSummaryMsg() (in WorkflowRunner)	_shutdownAll() (in WorkflowRunner)
__init__() (in StringBling)	_getWaitStatus() (in WorkflowRunner)	_startTaskManager() (in WorkflowRunner)
__package__ (in src)	_getWorkflowTaskRunner() (in TaskManager)	_startTasks() (in TaskManager)
__package__ (in src.pyflow)	_infoLog() (in TaskManager)	_stopAll (in StoppableThread)
__package__ (in src.pyflowConfig)	_infoLog() (in WorkflowRunner)	_stopAllWorkflows() (in WorkflowRunner)
__package__ (in src.pyflowTaskWrapper)	_initMessage() (in WorkflowRunner)	_validateFixParam() (in WorkflowRunnerThreadSharedData)
__repr__() (in Command)	_initRunning() (in WorkflowRunner)	_waitForTasksCore() (in WorkflowRunner)
__str__() (in StrFileObject)	_isDeadWalker() (in TaskNode)	_warningLog() (in WorkflowRunner)
__str__() (in TaskNode)	_isRunExhaustedNode() (in TaskDAG)	_whoami() (in WorkflowRunner)
_AbortWorkflowException (in WorkflowRunner)	_isTaskCompleteCore() (in WorkflowRunner)	_writeIfSet() (in TaskFileWriter)
_addTaskCore() (in WorkflowRunner)	_isTerm() (in TaskManager)	_writeMsg() (in StringBling)