Execution¶
Run a compiled graph inside an execution context, supply runtime components defined in Python, and access live state from a running graph.
An execution context for a compiled processing graph. |
|
Exception raised when processing finished without error, but for a reason other than reaching the end of the input. |
|
Exception raised by |
Run-time Python components¶
User-supplied Python objects passed to ExecutionContext
to handle input to and output from the graph.
Abstract base class for sinks (output handling processors) written in Python. |
|
Acquisition reader implemented in Python and supplied as an argument upon creation of the execution context. |
|
Bucket source implemented in Python and supplied as an argument upon creation of the execution context. |
Runtime access¶
Accessor objects expose live state from processors in running graphs. Use an
AccessTag declared at graph-definition time to look up
the corresponding accessor from ExecutionContext. The
accessor has a run-time-generated type but implements one of the
Accessor protocols.
Base protocol for run-time accessors. |
|
Run-time accessor for an |
|
Run-time accessor for a |
|
Run-time accessor for a |
|
Run-time accessor for a |
|
Run-time accessor for a |
|
Run-time accessor for a |