runtime

Run

Graph running infrastructure enabling parallel execution of nodes.

Functions

format_summaries(summaries, runtime)	Create a string containing interesting information from all execution summaries.
format_update(summaries)	Create a string containing a summary of waiting nodes.
init_signal(signal_object)	Initializes the signal handler for interrupts.
setup_build_logging(name[, level, file])	Sets up the build-time logging functionality, running in the main process.
setup_node_logging(name, logging_queue[, level])	Sets up the node logging functionality, running in a child process.

Classes

CustomFormat([fmt, datefmt, style, ...])	Custom formatter to show colors in log messages
Logger(message_queue[, name, level, file])	Logging node for all nodes in the graph.
RunPool(*items[, wait_time])	Context manager for running a pool of processes.
Runnable()	Represents an object that can be run as a separate process.
Status(value)	Component run status.
StatusHandler()	Descriptor logging any component status updates.
StatusUpdate(name, parents, status[, ...])	Summarizes the node status at completion of execution.

Exceptions

NodeException

Exception representing execution failure in a node.