AdjustQuantumHelper (inputs, …) |
Helper class for calling PipelineTaskConnections.adjustQuantum . |
ArgumentParser (name[, usage]) |
Argument parser for command-line tasks that is based on argparse.ArgumentParser . |
ButlerInitializedTaskRunner (TaskClass, parsedCmd) |
A TaskRunner for CmdLineTask s that require a butler keyword argument to be passed to their constructor. |
ButlerQuantumContext (butler, quantum) |
A Butler-like class specialized for a single quantum |
CmdLineTask ([config, name, parentTask, log]) |
Base class for command-line tasks: tasks that may be executed from the command-line. |
ConfigDatasetType (name) |
Dataset type specified by a config parameter. |
ConfigFileAction (option_strings, dest[, …]) |
argparse action to load config overrides from one or more files. |
ConfigValueAction (option_strings, dest[, …]) |
argparse action callback to override config parameters using name=value pairs from the command-line. |
DataIdContainer ([level]) |
Container for data IDs and associated data references. |
DatasetArgument ([name, help, default]) |
Dataset type specified by a command-line argument. |
DeferredDatasetRef |
Class which denotes that a datasetRef should be treated as deferred when interacting with the butler |
GraphBuilder (registry[, skipExistingIn, …]) |
GraphBuilder class is responsible for building task execution graph from a Pipeline. |
IncompatibleGraphError |
Exception class to indicate that a lookup by NodeId is impossible due to incompatibilities |
InputOnlyArgumentParser (name[, usage]) |
ArgumentParser for command-line tasks that don’t write any output. |
InputQuantizedConnection (**kwargs) |
|
InvalidQuantumError |
Exception that may be raised by PipelineTasks (and code they delegate to) in order to indicate logic bug or configuration problem. |
LabelSpecifier (labels, begin, end) |
A structure to specify a subset of labels to load |
LegacyTaskRunner (TaskClass, parsedCmd[, …]) |
A TaskRunner for CmdLineTask s which calls the Task ’s run method on a dataRef rather than the runDataRef method. |
NoWorkFound |
An exception raised when a Quantum should not exist because there is no work for it to do. |
NodeId (number, buildId) |
This represents an unique identifier of a node within an individual construction of a QuantumGraph . |
OutputQuantizedConnection (**kwargs) |
|
Pipeline (description) |
A Pipeline is a representation of a series of tasks to run, and the configuration for those tasks. |
PipelineDatasetTypes (initInputs, …) |
An immutable struct that classifies the dataset types used in a Pipeline . |
PipelineTask (*[, config, log, initInputs]) |
Base class for all pipeline tasks. |
PipelineTaskConfig |
Configuration class for PipelineTask |
PipelineTaskConnections (*, config) |
PipelineTaskConnections is a class used to declare desired IO when a PipelineTask is run by an activator |
QuantumGraph (quanta, …) |
QuantumGraph is a directed acyclic graph of QuantumNode objects |
QuantumNode (quantum, taskDef, nodeId) |
This class represents a node in the quantum graph. |
RepeatableQuantumError |
Exception that may be raised by PipelineTasks (and code they delegate to) in order to indicate that a repeatable problem that will not be addressed by retries. |
ResourceConfig |
Configuration for resource requirements. |
ScalarError |
Exception raised when dataset type is configured as scalar but there are multiple data IDs in a Quantum for that dataset. |
Struct (**keyArgs) |
A container to which you can add fields as attributes. |
Task ([config, name, parentTask, log]) |
Base class for data processing tasks. |
TaskDatasetTypes (initInputs, initOutputs, …) |
An immutable struct that extracts and classifies the dataset types used by a PipelineTask |
TaskDef (taskName, config[, taskClass, label]) |
TaskDef is a collection of information about task needed by Pipeline. |
TaskError |
Use to report errors for which a traceback is not useful. |
TaskFactory |
Abstract base class for task factory. |
TaskLogAdapter (logger, extra) |
A special logging adapter to provide log features for Task . |
TaskRunner (TaskClass, parsedCmd[, …]) |
Run a command-line task, using multiprocessing if requested. |