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

pipeline

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.