ingest_graph

lsst.pipe.base.quantum_graph.ingest_graph.ingest_graph(butler_config: str | Config, uri: str | ParseResult | ResourcePath | Path | None = None, *, transfer: str | None = 'move', batch_size: int = 10000, output_run: str | None = None) → None

Ingest a provenance graph into a butler repository.

Parameters:

butler_configstr

Path or alias for the butler repository, or a butler repository config object.

uriconvertible to lsst.resources.ResourcePath or None, optional

Location of the provenance quantum graph to ingest. None indicates that the quantum graph has already been ingested, but other ingests and/or deletions failed and need to be resumed.

batch_sizeint, optional

Number of datasets to process in each transaction.

output_runstr, optional

Output RUN collection name. Only needs to be provided if uri is None. If it is provided the output run in the graph is checked against it.

Notes

After this operation, no further processing may be done in the RUN collection.

If this process is interrupted, it can pick up where it left off if run again (at the cost of some duplicate work to figure out how much progress it had made).