lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask Class Reference

Inheritance diagram for lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask:

Public Member Functions
	__init__ (self, initInputs, **kwargs)
	runQuantum (self, butlerQC, inputRefs, outputRefs)

Public Attributes
	peakSchema
	schemaMapper
	schema

Protected Member Functions
	_makeSourceCatalog (self, mergedDetections, idFactory)

Detailed Description

Definition at line 169 of file deblendCoaddSourcesPipeline.py.

Constructor & Destructor Documentation

__init__()

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask.__init__	(		self,
			initInputs,
		**	kwargs )

Reimplemented in lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesSingleTask, and lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesMultiTask.

Definition at line 170 of file deblendCoaddSourcesPipeline.py.

    def __init__(self, initInputs, **kwargs):
        super().__init__(initInputs=initInputs, **kwargs)
        schema = initInputs["inputSchema"].schema
        self.peakSchema = initInputs["peakSchema"].schema
        self.schemaMapper = afwTable.SchemaMapper(schema)
        self.schemaMapper.addMinimalSchema(schema)
        self.schema = self.schemaMapper.getOutputSchema()
 

Member Function Documentation

_makeSourceCatalog()

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask._makeSourceCatalog ( self, mergedDetections, idFactory )

protected

Definition at line 184 of file deblendCoaddSourcesPipeline.py.

    def _makeSourceCatalog(self, mergedDetections, idFactory):
        # There may be gaps in the mergeDet catalog, which will cause the
        # source ids to be inconsistent. So we update the id factory
        # with the largest id already in the catalog.
        maxId = np.max(mergedDetections["id"])
        idFactory.notify(maxId)
        table = afwTable.SourceTable.make(self.schema, idFactory)
        sources = afwTable.SourceCatalog(table)
        sources.extend(mergedDetections, self.schemaMapper)
        return sources
 
 

runQuantum()

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask.runQuantum	(		self,
			butlerQC,
			inputRefs,
			outputRefs )

Reimplemented in lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesMultiTask.

Definition at line 178 of file deblendCoaddSourcesPipeline.py.

    def runQuantum(self, butlerQC, inputRefs, outputRefs):
        inputs = butlerQC.get(inputRefs)
        inputs["idFactory"] = self.config.idGenerator.apply(butlerQC.quantum.dataId).make_table_id_factory()
        outputs = self.run(**inputs)
        butlerQC.put(outputs, outputRefs)
 

Member Data Documentation

peakSchema

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask.peakSchema

Definition at line 173 of file deblendCoaddSourcesPipeline.py.

schema

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask.schema

Definition at line 176 of file deblendCoaddSourcesPipeline.py.

schemaMapper

lsst.pipe.tasks.deblendCoaddSourcesPipeline.DeblendCoaddSourcesBaseTask.schemaMapper

Definition at line 174 of file deblendCoaddSourcesPipeline.py.

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/pipe_tasks/gc07e1c2157+a98bf949bb/python/lsst/pipe/tasks/deblendCoaddSourcesPipeline.py