PipelineGraphFactory¶

class lsst.ctrl.mpexec.PipelineGraphFactory(pipeline: Pipeline, butler: Butler | None = None, select_tasks: str = '')¶

Bases: object

A factory for building and caching a PipelineGraph.

Parameters:

pipelinelsst.pipe.base.Pipeline: Pipeline definition to start from.
butlerlsst.daf.butler.Butler or None, optional: Butler that can be used to resolve dataset type definitions and get dimension schema.
select_tasksstr, optional: String expression that filters the tasks in the pipeline graph.

Attributes Summary

The original pipeline definition.

Methods Summary

__call__(*[, resolve, visualization_only])

Call self as a function.

Attributes Documentation

pipeline¶: The original pipeline definition.

Methods Documentation

__call__(*, resolve: bool = True, visualization_only: bool = False) → PipelineGraph¶: Call self as a function.