LSSTApplications
17.0+124,17.0+14,17.0+73,18.0.0+37,18.0.0+80,18.0.0-4-g68ffd23+4,18.1.0-1-g0001055+12,18.1.0-1-g03d53ef+5,18.1.0-1-g1349e88+55,18.1.0-1-g2505f39+44,18.1.0-1-g5315e5e+4,18.1.0-1-g5e4b7ea+14,18.1.0-1-g7e8fceb+4,18.1.0-1-g85f8cd4+48,18.1.0-1-g8ff0b9f+4,18.1.0-1-ga2c679d+1,18.1.0-1-gd55f500+35,18.1.0-10-gb58edde+2,18.1.0-11-g0997b02+4,18.1.0-13-gfe4edf0b+12,18.1.0-14-g259bd21+21,18.1.0-19-gdb69f3f+2,18.1.0-2-g5f9922c+24,18.1.0-2-gd3b74e5+11,18.1.0-2-gfbf3545+32,18.1.0-26-g728bddb4+5,18.1.0-27-g6ff7ca9+2,18.1.0-3-g52aa583+25,18.1.0-3-g8ea57af+9,18.1.0-3-gb69f684+42,18.1.0-3-gfcaddf3+6,18.1.0-32-gd8786685a,18.1.0-4-gf3f9b77+6,18.1.0-5-g1dd662b+2,18.1.0-5-g6dbcb01+41,18.1.0-6-gae77429+3,18.1.0-7-g9d75d83+9,18.1.0-7-gae09a6d+30,18.1.0-9-gc381ef5+4,w.2019.45
LSSTDataManagementBasePackage
|
Classes | |
class | DuplicateOutputError |
class | MissingTaskFactoryError |
class | PipelineDataCycleError |
Functions | |
def | isPipelineOrdered (pipeline, taskFactory=None) |
def | orderPipeline (pipeline) |
def lsst.pipe.base.pipeTools.isPipelineOrdered | ( | pipeline, | |
taskFactory = None |
|||
) |
Checks whether tasks in pipeline are correctly ordered. Pipeline is correctly ordered if for any DatasetType produced by a task in a pipeline all its consumer tasks are located after producer. Parameters ---------- pipeline : `pipe.base.Pipeline` Pipeline description. taskFactory: `pipe.base.TaskFactory`, optional Instance of an object which knows how to import task classes. It is only used if pipeline task definitions do not define task classes. Returns ------- True for correctly ordered pipeline, False otherwise. Raises ------ `ImportError` is raised when task class cannot be imported. `DuplicateOutputError` is raised when there is more than one producer for a dataset type. `MissingTaskFactoryError` is raised when TaskFactory is needed but not provided.
Definition at line 84 of file pipeTools.py.
def lsst.pipe.base.pipeTools.orderPipeline | ( | pipeline | ) |
Re-order tasks in pipeline to satisfy data dependencies. When possible new ordering keeps original relative order of the tasks. Parameters ---------- pipeline : `list` of `pipe.base.TaskDef` Pipeline description. Returns ------- Correctly ordered pipeline (`list` of `pipe.base.TaskDef` objects). Raises ------ `DuplicateOutputError` is raised when there is more than one producer for a dataset type. `PipelineDataCycleError` is also raised when pipeline has dependency cycles. `MissingTaskFactoryError` is raised when TaskFactory is needed but not provided.
Definition at line 135 of file pipeTools.py.