LoadDiaCatalogsTask#
- class lsst.ap.association.LoadDiaCatalogsTask(**kwargs)#
Bases:
PipelineTaskRetrieve DiaObjects and associated DiaSources from the Apdb given an input exposure.
Methods Summary
loadDiaForcedSources(diaObjects, region, ...)Load DiaForcedSources from the Apdb based on their diaObjectId.
loadDiaObjects(region, schema)Load DiaObjects from the Apdb based on their HTM location.
loadDiaSources(diaObjects, region, dateTime, ...)Load DiaSources from the Apdb based on their diaObjectId or location.
run(regionTime)Preload all DiaObjects and DiaSources from the Apdb given the current exposure.
Methods Documentation
- loadDiaForcedSources(diaObjects, region, dateTime, schema)#
Load DiaForcedSources from the Apdb based on their diaObjectId.
Parameters#
- diaObjects
pandas.DataFrame DiaObjects to load the history for, indexed by
diaObjectId.- region
sphgeom.Region Region of interest.
- dateTime
astropy.time.Time Time of the current visit
- schema‘dict’ of
lsst.dax.apdb.apdbSchema.ApdbSchema A dict of the schemas in the apdb.
Returns#
- diaForcedSources
pandas.DataFrame DiaForcedSources loaded from the Apdb that are associated with
diaObjects, indexed bydiaObjectIdanddiaForcedSourceId.
- diaObjects
- loadDiaObjects(region, schema)#
Load DiaObjects from the Apdb based on their HTM location.
Parameters#
- region
sphgeom.Region Region of interest.
- schema‘dict’ of
lsst.dax.apdb.apdbSchema.ApdbSchema A dict of the schemas in the apdb.
Returns#
- diaObjects
pandas.DataFrame DiaObjects loaded from the Apdb that are within
region, indexed bydiaObjectId.
- region
- loadDiaSources(diaObjects, region, dateTime, schema)#
Load DiaSources from the Apdb based on their diaObjectId or location.
Parameters#
- diaObjects
pandas.DataFrame DiaObjects to load the history for, indexed by
diaObjectId.- region
sphgeom.Region Region of interest.
- dateTime
astropy.time.Time Time of the current visit
- schema‘dict’ of
lsst.dax.apdb.apdbSchema.ApdbSchema A dict of the schemas in the apdb.
Returns#
- diaSources
pandas.DataFrame DiaSources loaded from the Apdb that are within
regionand associated withdiaObjects, indexed bydiaObjectId,band, anddiaSourceId.
- diaObjects
- run(regionTime)#
Preload all DiaObjects and DiaSources from the Apdb given the current exposure.
Parameters#
- regionTime
lsst.pipe.base.utils.RegionTimeInfo A serializable container for a sky region and timespan.
Returns#
- result
lsst.pipe.base.Struct Results struct with components.
diaObjects: Complete set of DiaObjects covering the input exposure padded byangleMargin. DataFrame is indexed by thediaObjectIdcolumn. (pandas.DataFrame)diaSources: Complete set of DiaSources covering the input exposure padded byangleMargin. DataFrame is indexed bydiaObjectId,band,diaSourceIdcolumns. (pandas.DataFrame)diaForcedSources: Complete set of forced photometered fluxes on the past 12 months of difference images at DiaObject locations, indexed bydiaObjectIdanddiaForcedSourceId. (pandas.DataFrame)
Raises#
- RuntimeError
Raised if the Database query failed to load DiaObjects.
- regionTime