Class TaskManager

This constructor should always be called with keyword arguments. Arguments are:

*group* should be None; reserved for future extension when a ThreadGroup class is implemented.

*target* is the callable object to be invoked by the run() method. Defaults to None, meaning nothing is called.

*name* is the thread name. By default, a unique name is constructed of the form "Thread-N" where N is a small decimal number.

*args* is the argument tuple for the target invocation. Defaults to ().

*kwargs* is a dictionary of keyword arguments for the target invocation. Defaults to {}.

If a subclass overrides the constructor, it must make sure to invoke the base class constructor (Thread.__init__()) before doing anything else to the thread.

Parameters:

• cdata - data from WorkflowRunner instance which will be constant during the lifetime of the TaskManager, should be safe to lookup w/o locking
• tdag - task graph

Overrides: object.__init__

TaskManager runs so long as there are outstanding jobs

Overrides: threading.Thread.run

Check the set of running tasks to see if they've completed and update Node status accordingly:

Decorators:

• @lockMethod

Cancel a task and all of its children, without labeling the canceled tasks as errors

A canceled task will be stopped if it is running, or unqueued if it is waiting, and will be put into the waiting/ignored state unless it has already completed.

Decorators:

• @lockMethod

thread specific stop method, may be overridden to add async thread-specific kill behavior

Decorators:

• @lockMethod

Overrides: StoppableThread.stop

(inherited documentation)