lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux Class Reference

Inheritance diagram for lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux:

Public Member Functions
	getExecutionOrder (cls)
	calculate (self, diaObjects, diaSources, filterDiaSources, band, **kwargs)

Static Public Attributes
	ConfigClass = WeightedMeanDiaPsfFluxConfig
list	outputCols = ["psfFluxMean", "psfFluxMeanErr", "psfFluxNdata"]
str	plugType = "multi"
bool	needsFilter = True

Detailed Description

Compute the weighted mean and mean error on the point source fluxes
of the DiaSource measured on the difference image.

Additionally store number of usable data points.

Definition at line 264 of file diaCalculationPlugins.py.

Member Function Documentation

calculate()

lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.calculate	(		self,
			diaObjects,
			diaSources,
			filterDiaSources,
			band,
		**	kwargs )

Compute the weighted mean and mean error of the point source flux.

Parameters
----------
diaObject : `dict`
    Summary object to store values in.
diaSources : `pandas.DataFrame`
    DataFrame representing all diaSources associated with this
    diaObject.
filterDiaSources : `pandas.DataFrame`
    DataFrame representing diaSources associated with this
    diaObject that are observed in the band pass ``band``.
band : `str`
    Simple, string name of the filter for the flux being calculated.
**kwargs
    Any additional keyword arguments that may be passed to the plugin.

Reimplemented from lsst.meas.base.diaCalculation.DiaObjectCalculationPlugin.

Definition at line 282 of file diaCalculationPlugins.py.

                  **kwargs):
        """Compute the weighted mean and mean error of the point source flux.
 
        Parameters
        ----------
        diaObject : `dict`
            Summary object to store values in.
        diaSources : `pandas.DataFrame`
            DataFrame representing all diaSources associated with this
            diaObject.
        filterDiaSources : `pandas.DataFrame`
            DataFrame representing diaSources associated with this
            diaObject that are observed in the band pass ``band``.
        band : `str`
            Simple, string name of the filter for the flux being calculated.
        **kwargs
            Any additional keyword arguments that may be passed to the plugin.
        """
        meanName = "{}_psfFluxMean".format(band)
        errName = "{}_psfFluxMeanErr".format(band)
        nDataName = "{}_psfFluxNdata".format(band)
        if meanName not in diaObjects.columns:
            diaObjects[meanName] = np.nan
        if errName not in diaObjects.columns:
            diaObjects[errName] = np.nan
        if nDataName not in diaObjects.columns:
            diaObjects[nDataName] = 0
 
        def _weightedMean(df):
            tmpDf = df[~np.logical_or(np.isnan(df["psfFlux"]),
                                      np.isnan(df["psfFluxErr"]))]
            tot_weight = np.nansum(1 / tmpDf["psfFluxErr"] ** 2)
            fluxMean = np.nansum(tmpDf["psfFlux"]
                                 / tmpDf["psfFluxErr"] ** 2)
            fluxMean /= tot_weight
            if tot_weight > 0:
                fluxMeanErr = np.sqrt(1 / tot_weight)
            else:
                fluxMeanErr = np.nan
            nFluxData = len(tmpDf)
 
            return pd.Series({meanName: fluxMean,
                              errName: fluxMeanErr,
                              nDataName: nFluxData},
                             dtype="object")
 
        diaObjects.loc[:, [meanName, errName, nDataName]] = \
            filterDiaSources.apply(_weightedMean)
 
 

getExecutionOrder()

lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.getExecutionOrder

(

cls

)

Used to set the relative order of plugin execution.

    The values returned by `getExecutionOrder` are compared across all
    plugins, and smaller numbers run first.

    Notes
    -----
    `CatalogCalculationPlugin`\s must run with
    `BasePlugin.DEFAULT_CATALOGCALCULATION` or higher.

    All plugins must implement this method with an appropriate run level

Reimplemented from lsst.meas.base.catalogCalculation.CatalogCalculationPlugin.

Definition at line 277 of file diaCalculationPlugins.py.

    def getExecutionOrder(cls):
        return cls.DEFAULT_CATALOGCALCULATION
 

Member Data Documentation

ConfigClass

lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.ConfigClass = WeightedMeanDiaPsfFluxConfig

static

Definition at line 271 of file diaCalculationPlugins.py.

needsFilter

bool lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.needsFilter = True

static

Definition at line 274 of file diaCalculationPlugins.py.

outputCols

list lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.outputCols = ["psfFluxMean", "psfFluxMeanErr", "psfFluxNdata"]

static

Definition at line 272 of file diaCalculationPlugins.py.

plugType

str lsst.meas.base.diaCalculationPlugins.WeightedMeanDiaPsfFlux.plugType = "multi"

static

Definition at line 273 of file diaCalculationPlugins.py.

---

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

• /j/snowflake/release/lsstsw/stack/lsst-scipipe-8.0.0/Linux64/meas_base/g212a7c68fe+a4f2ea4efa/python/lsst/meas/base/diaCalculationPlugins.py