lsst.pipe.base.pipelineIR.TaskIR Class Reference

Public Member Functions
Dict[str, Union[str, List[dict]]]	to_primitives (self)
def	add_or_update_config (self, ConfigIR other_config)
def	__eq__ (self, object other)

Public Attributes
	config

Detailed Description

Intermediate representation of tasks read from a pipeline yaml file.

Definition at line 327 of file pipelineIR.py.

Member Function Documentation

__eq__()

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

Definition at line 369 of file pipelineIR.py.

    def __eq__(self, other: object):
        if not isinstance(other, TaskIR):
            return False
        elif all(getattr(self, attr) == getattr(other, attr) for attr in
                 ("label", "klass", "config")):
            return True
        else:
            return False
 
 
@dataclass

add_or_update_config()

def lsst.pipe.base.pipelineIR.TaskIR.add_or_update_config	(		self,
		ConfigIR	other_config
	)

Adds a `ConfigIR` to this task if one is not present. Merges configs
if there is a `ConfigIR` present and the dataId keys of both configs
match, otherwise adds a new entry to the config list. The exception to
the above is that if either the last config or other_config has a
python block, then other_config is always added, as python blocks can
modify configs in ways that cannot be predicted.

Parameters
----------
other_config : `ConfigIR`
    A `ConfigIR` instance to add or merge into the config attribute of
    this task.

Definition at line 350 of file pipelineIR.py.

    def add_or_update_config(self, other_config: ConfigIR):
        """Adds a `ConfigIR` to this task if one is not present. Merges configs
        if there is a `ConfigIR` present and the dataId keys of both configs
        match, otherwise adds a new entry to the config list. The exception to
        the above is that if either the last config or other_config has a
        python block, then other_config is always added, as python blocks can
        modify configs in ways that cannot be predicted.
 
        Parameters
        ----------
        other_config : `ConfigIR`
            A `ConfigIR` instance to add or merge into the config attribute of
            this task.
        """
        if not self.config:
            self.config = [other_config]
            return
        self.config.extend(self.config.pop().maybe_merge(other_config))
 

to_primitives()

Dict[str, Union[str, List[dict]]] lsst.pipe.base.pipelineIR.TaskIR.to_primitives

(

self

)

Convert to a representation used in yaml serialization

Definition at line 342 of file pipelineIR.py.

    def to_primitives(self) -> Dict[str, Union[str, List[dict]]]:
        """Convert to a representation used in yaml serialization
        """
        accumulate: Dict[str, Union[str, List[dict]]] = {'class': self.klass}
        if self.config:
            accumulate['config'] = [c.to_primitives() for c in self.config]
        return accumulate
 

Member Data Documentation

config

lsst.pipe.base.pipelineIR.TaskIR.config

Definition at line 365 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