lsst.meas.deblender.deblend.SourceDeblendTask Class Reference

Split blended sources into individual sources. More...

Inheritance diagram for lsst.meas.deblender.deblend.SourceDeblendTask:

Public Member Functions
def	__init__
	Create the task, adding necessary fields to the given schema. More...
def	addSchemaKeys
def	run
	Run deblend(). More...
def	deblend
	Deblend. More...
def	preSingleDeblendHook
def	postSingleDeblendHook
def	isLargeFootprint
def	isMasked
def	skipParent
def	calculateBlendedness

Public Attributes
	peakSchemaMapper
	nChildKey
	psfKey
	psfCenterKey
	psfFluxKey
	tooManyPeaksKey
	tooBigKey
	maskedKey
	deblendFailedKey
	deblendSkippedKey
	deblendRampedTemplateKey
	deblendPatchedTemplateKey
	hasStrayFluxKey
	blendednessKey

Static Public Attributes
	ConfigClass = SourceDeblendConfig

Private Member Functions
def	_getPsfFwhm

Static Private Attributes
string	_DefaultName = "sourceDeblend"

Detailed Description

Split blended sources into individual sources.

This task has no return value; it only modifies the SourceCatalog in-place.

Definition at line 132 of file deblend.py.

Constructor & Destructor Documentation

def lsst.meas.deblender.deblend.SourceDeblendTask.__init__	(		self,
			schema,
			peakSchema = None,
			kwargs
	)

Create the task, adding necessary fields to the given schema.

Parameters

[in,out]	schema	Schema object for measurement fields; will be modified in-place.
[in]	peakSchema	Schema of Footprint Peaks that will be passed to the deblender. Any fields beyond the PeakTable minimal schema will be transferred to the main source Schema. If None, no fields will be transferred from the Peaks.
[in]	**kwargs	Passed to Task.__init__.

Definition at line 143 of file deblend.py.

    def __init__(self, schema, peakSchema=None, **kwargs):
        """!
        Create the task, adding necessary fields to the given schema.

        @param[in,out] schema        Schema object for measurement fields; will be modified in-place.
        @param[in]     peakSchema    Schema of Footprint Peaks that will be passed to the deblender.
                                     Any fields beyond the PeakTable minimal schema will be transferred
                                     to the main source Schema.  If None, no fields will be transferred
                                     from the Peaks.
        @param[in]     **kwargs      Passed to Task.__init__.
        """
        pipeBase.Task.__init__(self, **kwargs)
        peakMinimalSchema = afwDet.PeakTable.makeMinimalSchema()
        if peakSchema is None:
            # In this case, the peakSchemaMapper will transfer nothing, but we'll still have one
            # to simplify downstream code
            self.peakSchemaMapper = afwTable.SchemaMapper(peakMinimalSchema, schema)
        else:
            self.peakSchemaMapper = afwTable.SchemaMapper(peakSchema, schema)
            for item in peakSchema:
                if item.key not in peakMinimalSchema:
                    self.peakSchemaMapper.addMapping(item.key, item.field)
                    # Because SchemaMapper makes a copy of the output schema you give its ctor, it isn't
                    # updating this Schema in place.  That's probably a design flaw, but in the meantime,
                    # we'll keep that schema in sync with the peakSchemaMapper.getOutputSchema() manually,
                    # by adding the same fields to both.
                    schema.addField(item.field)
            assert schema == self.peakSchemaMapper.getOutputSchema(), "Logic bug mapping schemas"
        self.addSchemaKeys(schema)