LSST Applications g04e9c324dd+8c5ae1fdc5,g134cb467dc+1b3060144d,g18429d2f64+f642bf4753,g199a45376c+0ba108daf9,g1fd858c14a+2dcf163641,g262e1987ae+7b8c96d2ca,g29ae962dfc+3bd6ecb08a,g2cef7863aa+aef1011c0b,g35bb328faa+8c5ae1fdc5,g3fd5ace14f+53e1a9e7c5,g4595892280+fef73a337f,g47891489e3+2efcf17695,g4d44eb3520+642b70b07e,g53246c7159+8c5ae1fdc5,g67b6fd64d1+2efcf17695,g67fd3c3899+b70e05ef52,g74acd417e5+317eb4c7d4,g786e29fd12+668abc6043,g87389fa792+8856018cbb,g89139ef638+2efcf17695,g8d7436a09f+3be3c13596,g8ea07a8fe4+9f5ccc88ac,g90f42f885a+a4e7b16d9b,g97be763408+ad77d7208f,g9dd6db0277+b70e05ef52,ga681d05dcb+a3f46e7fff,gabf8522325+735880ea63,gac2eed3f23+2efcf17695,gb89ab40317+2efcf17695,gbf99507273+8c5ae1fdc5,gd8ff7fe66e+b70e05ef52,gdab6d2f7ff+317eb4c7d4,gdc713202bf+b70e05ef52,gdfd2d52018+b10e285e0f,ge365c994fd+310e8507c4,ge410e46f29+2efcf17695,geaed405ab2+562b3308c0,gffca2db377+8c5ae1fdc5,w.2025.35
LSST Data Management Base Package
Loading...
Searching...
No Matches
lsst.pipe.tasks.postprocess.for Class Reference
Inheritance diagram for lsst.pipe.tasks.postprocess.for:

Static Public Attributes

 funcs :
 
 sourceId :
 
Index x :
 
slot_Centroid_x y :
 
slot_Centroid_y psfFlux :
 
LocalNanojansky args :
 
 psfFluxErr :
 
LocalNanojanskyErr args :
 
 flags :
 

Detailed Description

_defaultRefFlags = []
_defaultFuncs = ()

def __init__(self, handles, functors, filt=None, flags=None, refFlags=None, forcedFlags=None):
    self.handles = handles
    self.functors = functors

    self.filt = filt
    self.flags = list(flags) if flags is not None else []
    self.forcedFlags = list(forcedFlags) if forcedFlags is not None else []
    self.refFlags = list(self._defaultRefFlags)
    if refFlags is not None:
        self.refFlags += list(refFlags)

    self._df = None

@property
def defaultFuncs(self):
    funcs = dict(self._defaultFuncs)
    return funcs

@property
def func(self):
    additionalFuncs = self.defaultFuncs
    additionalFuncs.update({flag: Column(flag, dataset="forced_src") for flag in self.forcedFlags})
    additionalFuncs.update({flag: Column(flag, dataset="ref") for flag in self.refFlags})
    additionalFuncs.update({flag: Column(flag, dataset="meas") for flag in self.flags})

    if isinstance(self.functors, CompositeFunctor):
        func = self.functors
    else:
        func = CompositeFunctor(self.functors)

    func.funcDict.update(additionalFuncs)
    func.filt = self.filt

    return func

@property
def noDupCols(self):
    return [name for name, func in self.func.funcDict.items() if func.noDup]

@property
def df(self):
    if self._df is None:
        self.compute()
    return self._df

def compute(self, dropna=False, pool=None):
    # map over multiple handles
    if type(self.handles) in (list, tuple):
        if pool is None:
            dflist = [self.func(handle, dropna=dropna) for handle in self.handles]
        else:
            # TODO: Figure out why this doesn't work (pyarrow pickling
            # issues?)
            dflist = pool.map(functools.partial(self.func, dropna=dropna), self.handles)
        self._df = pd.concat(dflist)
    else:
        self._df = self.func(self.handles, dropna=dropna)

    return self._df


class TransformCatalogBaseConnections(pipeBase.PipelineTaskConnections,
                                  dimensions=()):
inputCatalog = connectionTypes.Input(
    name="",
    storageClass="DataFrame",
)
outputCatalog = connectionTypes.Output(
    name="",
    storageClass="ArrowAstropy",
)


class TransformCatalogBaseConfig(pipeBase.PipelineTaskConfig,
                             pipelineConnections=TransformCatalogBaseConnections):
functorFile = pexConfig.Field(
    dtype=str,
    doc="Path to YAML file specifying Science Data Model functors to use "
        "when copying columns and computing calibrated values.",
    default=None,
    optional=True
)
primaryKey = pexConfig.Field(
    dtype=str,
    doc="Name of column to be set as the DataFrame index. If None, the index"
        "will be named `id`",
    default=None,
    optional=True
)
columnsFromDataId = pexConfig.ListField(
    dtype=str,
    default=None,
    optional=True,
    doc="Columns to extract from the dataId",
)


class TransformCatalogBaseTask(pipeBase.PipelineTask):

Definition at line 724 of file postprocess.py.

Member Data Documentation

◆ args [1/2]

LocalNanojansky lsst.pipe.tasks.postprocess.for.args :
static

Definition at line 748 of file postprocess.py.

◆ args [2/2]

LocalNanojanskyErr lsst.pipe.tasks.postprocess.for.args :
static

Definition at line 755 of file postprocess.py.

◆ flags

lsst.pipe.tasks.postprocess.for.flags :
static

Definition at line 760 of file postprocess.py.

◆ funcs

lsst.pipe.tasks.postprocess.for.funcs :
static

Definition at line 737 of file postprocess.py.

◆ psfFlux

slot_Centroid_y lsst.pipe.tasks.postprocess.for.psfFlux :
static

Definition at line 746 of file postprocess.py.

◆ psfFluxErr

lsst.pipe.tasks.postprocess.for.psfFluxErr :
static

Definition at line 753 of file postprocess.py.

◆ sourceId

lsst.pipe.tasks.postprocess.for.sourceId :
static

Definition at line 738 of file postprocess.py.

◆ x

Index lsst.pipe.tasks.postprocess.for.x :
static

Definition at line 740 of file postprocess.py.

◆ y

slot_Centroid_x lsst.pipe.tasks.postprocess.for.y :
static

Definition at line 743 of file postprocess.py.


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