lsst.pipe.base.pipelineIR.ImportIR Class Reference

Public Member Functions
"PipelineIR"	toPipelineIR (self)
def	__eq__ (self, object other)

Static Public Attributes
	bool

Detailed Description

An intermediate representation of imported pipelines

Definition at line 380 of file pipelineIR.py.

Member Function Documentation

__eq__()

def lsst.pipe.base.pipelineIR.ImportIR.__eq__	(		self,
		object	other
	)

Definition at line 449 of file pipelineIR.py.

    def __eq__(self, other: object):
        if not isinstance(other, ImportIR):
            return False
        elif all(getattr(self, attr) == getattr(other, attr) for attr in
                 ("location", "include", "exclude", "importContracts")):
            return True
        else:
            return False
 
 

toPipelineIR()

"PipelineIR" lsst.pipe.base.pipelineIR.ImportIR.toPipelineIR

(

self

)

Load in the Pipeline specified by this object, and turn it into a
PipelineIR instance.

Returns
-------
pipeline : `PipelineIR`
    A pipeline generated from the imported pipeline file

Definition at line 408 of file pipelineIR.py.

    def toPipelineIR(self) -> "PipelineIR":
        """Load in the Pipeline specified by this object, and turn it into a
        PipelineIR instance.
 
        Returns
        -------
        pipeline : `PipelineIR`
            A pipeline generated from the imported pipeline file
        """
        if self.include and self.exclude:
            raise ValueError("Both an include and an exclude list cant be specified"
                             " when declaring a pipeline import")
        tmp_pipeline = PipelineIR.from_uri(os.path.expandvars(self.location))
        if self.instrument is not KeepInstrument:
            tmp_pipeline.instrument = self.instrument
 
        included_labels = set()
        for label in tmp_pipeline.tasks:
            if (self.include and label in self.include) or (self.exclude and label not in self.exclude)\
                    or (self.include is None and self.exclude is None):
                included_labels.add(label)
 
        # Handle labeled subsets being specified in the include or exclude
        # list, adding or removing labels.
        if self.include is not None:
            subsets_in_include = tmp_pipeline.labeled_subsets.keys() & self.include
            for label in subsets_in_include:
                included_labels.update(tmp_pipeline.labeled_subsets[label].subset)
 
        elif self.exclude is not None:
            subsets_in_exclude = tmp_pipeline.labeled_subsets.keys() & self.exclude
            for label in subsets_in_exclude:
                included_labels.difference_update(tmp_pipeline.labeled_subsets[label].subset)
 
        tmp_pipeline = tmp_pipeline.subset_from_labels(included_labels)
 
        if not self.importContracts:
            tmp_pipeline.contracts = []
 
        return tmp_pipeline
 

Member Data Documentation

bool

lsst.pipe.base.pipelineIR.ImportIR.bool

static

Definition at line 397 of file pipelineIR.py.

---

The documentation for this class was generated from the following file:

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-0.4.3/Linux64/pipe_base/22.0.1+94e66cc9ed/python/lsst/pipe/base/pipelineIR.py