mock_pipeline_graph

lsst.pipe.base.tests.mocks.mock_pipeline_graph(original_graph: PipelineGraph, unmocked_dataset_types: Iterable[str] = (), force_failures: Mapping[str, tuple[str, type[Exception] | None]] | None = None) → PipelineGraph

Create mocks for a full pipeline graph.

Parameters:

original_graphPipelineGraph

Original tasks and configuration to mock.

unmocked_dataset_typesIterable [ str ], optional

Names of overall-input dataset types that should not be replaced with mocks.

force_failuresMapping [ str, tuple [ str, type [ Exception ] or None ] ]

Mapping from original task label to a 2-tuple indicating that some quanta should raise an exception when executed. The first entry is a data ID match using the butler expression language (i.e. a string of the sort passed as the where argument to butler query methods), while the second is the type of exception to raise when the quantum data ID matches the expression. An exception type of None uses the default, ValueError.

Returns:

mockedPipelineGraph

Pipeline graph using MockPipelineTask configurations that target the original tasks. Never resolved.