lsst.pipe.base.connections.PipelineTaskConnectionDict Class Reference

Inheritance diagram for lsst.pipe.base.connections.PipelineTaskConnectionDict:

Public Member Functions
def	__init__ (self, *args, **kwargs)
def	__setitem__ (self, name, value)

Detailed Description

This is a special dict class used by PipelineTaskConnectionMetaclass

This dict is used in PipelineTaskConnection class creation, as the
dictionary that is initially used as __dict__. It exists to
intercept connection fields declared in a PipelineTaskConnection, and
what name is used to identify them. The names are then added to class
level list according to the connection type of the class attribute. The
names are also used as keys in a class level dictionary associated with
the corresponding class attribute. This information is a duplicate of
what exists in __dict__, but provides a simple place to lookup and
iterate on only these variables.

Definition at line 51 of file connections.py.

Constructor & Destructor Documentation

__init__()

def lsst.pipe.base.connections.PipelineTaskConnectionDict.__init__	(		self,
		*	args,
		**	kwargs
	)

Definition at line 64 of file connections.py.

    def __init__(self, *args, **kwargs):
        super().__init__(*args, **kwargs)
        # Initialize class level variables used to track any declared
        # class level variables that are instances of
        # connectionTypes.BaseConnection
        self.data['inputs'] = []
        self.data['prerequisiteInputs'] = []
        self.data['outputs'] = []
        self.data['initInputs'] = []
        self.data['initOutputs'] = []
        self.data['allConnections'] = {}
 

Member Function Documentation

__setitem__()

def lsst.pipe.base.connections.PipelineTaskConnectionDict.__setitem__	(		self,
			name,
			value
	)

Definition at line 76 of file connections.py.

    def __setitem__(self, name, value):
        if isinstance(value, Input):
            self.data['inputs'].append(name)
        elif isinstance(value, PrerequisiteInput):
            self.data['prerequisiteInputs'].append(name)
        elif isinstance(value, Output):
            self.data['outputs'].append(name)
        elif isinstance(value, InitInput):
            self.data['initInputs'].append(name)
        elif isinstance(value, InitOutput):
            self.data['initOutputs'].append(name)
        # This should not be an elif, as it needs tested for
        # everything that inherits from BaseConnection
        if isinstance(value, BaseConnection):
            object.__setattr__(value, 'varName', name)
            self.data['allConnections'][name] = value
        # defer to the default behavior
        super().__setitem__(name, value)
 
 

---

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/connections.py