mock_pipeline_graph

lsst.pipe.base.tests.mocks.mock_pipeline_graph(original_graph: PipelineGraph, unmocked_dataset_types: Iterable[str] = (), force_failures: Mapping[str, ForcedFailure] | 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, ForcedFailure ]

Mapping from original task label to information about an exception one or more quanta for this task should raise.

Returns:

mockedPipelineGraph

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