huntsman.drp.lsst.utils.pipeline

Temporary wrappers around cli commands until we agree on a better approach to running LSST.

Functions

parse_pipeline_name(pipeline[, extension])	Get the absolute path to the pipeline.
pipetask_run(pipeline_name, root_directory)	Use the LSST pipetask cli to run a pipeline. :param pipeline_name: The pipeline name to run. :type pipeline_name: str :param root_directory: The Butler root directory. :type root_directory: str :param input_collections: The Butler input collections. :type input_collections: str, optional :param output_collection: The output collection. :type output_collection: str, optional :param dataIds: The dataIds to process. :type dataIds: list of dict, optional :param args_str: Extra arguments. :type args_str: str, optional :param register_dataset_types: butler. :type register_dataset_types: bool, optional). If True (default :param config: Config overrides for LSST tasks. :type config: dict, optional :param instrument: The full python class name of the instrument. Used for applying default config overrides. :type instrument: str, optional :param nproc: The number of processes to use. Default: 1. :type nproc: int, optional :param start_method: The multiprocessing start method to use. Default: "spawn". :type start_method: str, optional :param **kwargs: Parsed to _run_pipetask_cmd.
plot_quantum_graph(pipeline, filename)	Plot the quantum graph associated with the pipeline.