lsst.pipe.base.graph._implDetails._DatasetTracker Class Reference

Inheritance diagram for lsst.pipe.base.graph._implDetails._DatasetTracker:

Public Member Functions
def	__init__ (self)
def	addInput (self, _T key, _U value)
def	addOutput (self, _T key, _U value)
Set[_U]	getInputs (self, _T key)
Optional[_U]	getOutput (self, _T key)
Set[_U]	getAll (self, _T key)
nx.DiGraph	makeNetworkXGraph (self)
Set[_T]	keys (self)

Detailed Description

Definition at line 49 of file _implDetails.py.

Constructor & Destructor Documentation

__init__()

def lsst.pipe.base.graph._implDetails._DatasetTracker.__init__

(

self

)

Definition at line 50 of file _implDetails.py.

    def __init__(self):
        self._container: DefaultDict[_T, _DatasetTrackerElement[_U]] = defaultdict(_DatasetTrackerElement)
 

Member Function Documentation

addInput()

def lsst.pipe.base.graph._implDetails._DatasetTracker.addInput	(		self,
		_T	key,
		_U	value
	)

Definition at line 53 of file _implDetails.py.

    def addInput(self, key: _T, value: _U):
        self._container[key].inputs.add(value)
 

addOutput()

def lsst.pipe.base.graph._implDetails._DatasetTracker.addOutput	(		self,
		_T	key,
		_U	value
	)

Definition at line 56 of file _implDetails.py.

    def addOutput(self, key: _T, value: _U):
        element = self._container[key]
        if element.output is not None:
            raise ValueError(f"Only one output for key {key} is allowed, "
                             f"the current output is set to {element.output}")
        element.output = value
 

getAll()

Set[_U] lsst.pipe.base.graph._implDetails._DatasetTracker.getAll	(		self,
		_T	key
	)

Definition at line 69 of file _implDetails.py.

    def getAll(self, key: _T) -> Set[_U]:
        output = self._container[key].output
        if output is not None:
            return self._container[key].inputs.union((output,))
        return set(self._container[key].inputs)
 

getInputs()

Set[_U] lsst.pipe.base.graph._implDetails._DatasetTracker.getInputs	(		self,
		_T	key
	)

Definition at line 63 of file _implDetails.py.

    def getInputs(self, key: _T) -> Set[_U]:
        return self._container[key].inputs
 

getOutput()

Optional[_U] lsst.pipe.base.graph._implDetails._DatasetTracker.getOutput	(		self,
		_T	key
	)

Definition at line 66 of file _implDetails.py.

    def getOutput(self, key: _T) -> Optional[_U]:
        return self._container[key].output
 

keys()

Set[_T] lsst.pipe.base.graph._implDetails._DatasetTracker.keys

(

self

)

Definition at line 96 of file _implDetails.py.

    def keys(self) -> Set[_T]:
        return set(self._container.keys())

makeNetworkXGraph()

nx.DiGraph lsst.pipe.base.graph._implDetails._DatasetTracker.makeNetworkXGraph

(

self

)

Definition at line 75 of file _implDetails.py.

    def makeNetworkXGraph(self) -> nx.DiGraph:
        graph = nx.DiGraph()
        graph.add_edges_from(self._datasetDictToEdgeIterator())
        if None in graph.nodes():
            graph.remove_node(None)
        return graph
 

---

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/graph/_implDetails.py