lsst.drp.tasks

PipelineTasks that are used only in data release pipelines (not alert or calibration production). Note that many tasks that fit this description remain in pipe_tasks for historical reasons.

Using lsst.drp.tasks

Task reference

Pipeline tasks

ForcedPhotCoaddTask

A pipeline task for performing forced measurement on coadd images.

GbdesAstrometricFitTask

Calibrate the WCS across multiple visits of the same field using the GBDES package.

MakeDirectWarpTask

Warp single-detector images onto a common projection.

MakePsfMatchedWarpTask

Base class for all pipeline tasks.

ReprocessVisitImageTask

Use the visit-level calibrations to perform detection and measurement on the single frame exposures and produce a "final" exposure and catalog.

UpdateVisitSummaryTask

A pipeline task that creates a new visit-summary table after all lsst.afw.image.Exposure components have been finalized.

Contributing

lsst.drp.tasks is developed at https://github.com/lsst/drp_tasks. You can find Jira issues for this module under the drp_tasks component.

Python API reference

lsst.drp.tasks.assemble_cell_coadd Module

Classes

AssembleCellCoaddTask(*args, **kwargs)	Assemble a cell-based coadded image from a set of warps.
AssembleCellCoaddConfig(*args, **kw)
ConvertMultipleCellCoaddToExposureTask(*[, ...])	An after burner PipelineTask that converts a cell-based coadd from MultipleCellCoadd format to ExposureF format.

lsst.drp.tasks.assemble_chi2_coadd Module

Functions

calculateKernelSize(sigma[, nSigmaForKernel])	Calculate the size of the smoothing kernel.
convolveImage(image, psf)	Convolve an image with a psf

Classes

AssembleChi2CoaddConfig(*args, **kw)
AssembleChi2CoaddConnections(*[, config])
AssembleChi2CoaddTask(initInputs, **kwargs)	Assemble a chi^2 coadd from a collection of multi-band coadds
DetectChi2SourcesConfig(*args, **kw)
DetectChi2SourcesConnections(*[, config])
DetectChi2SourcesTask([schema])
Psf
SkyMapIdGeneratorConfig(*args, **kw)	Configuration class for generating integer IDs from {tract, patch, [band]} data IDs.
SourceDetectionTask([schema])	Detect peaks and footprints of sources in an image.

lsst.drp.tasks.assemble_coadd Module

Classes

AssembleCoaddTask(*args, **kwargs)	Assemble a coadded image from a set of warps.
AssembleCoaddConnections(*[, config])
AssembleCoaddConfig(*args, **kw)
CompareWarpAssembleCoaddTask(*args, **kwargs)	Assemble a compareWarp coadded image from a set of warps by masking artifacts detected by comparing PSF-matched warps.
CompareWarpAssembleCoaddConfig(*args, **kw)

lsst.drp.tasks.build_camera Module

Classes

BuildCameraFromAstrometryConfig(*args, **kw)	Configuration for BuildCameraTask.
BuildCameraFromAstrometryTask(**kwargs)	Build an lsst.afw.cameraGeom.Camera object out of the gbdes polynomials mapping from pixels to the tangent plane.

lsst.drp.tasks.compute_object_epochs Module

Classes

ComputeObjectEpochsConfig(*args, **kw)
ComputeObjectEpochsConnections(*[, config])
ComputeObjectEpochsTask(*[, config, log, ...])	Collect mean epochs for the observations that went into each object.
Table([data, masked, names, dtype, meta, ...])	A class to represent tables of heterogeneous data.

lsst.drp.tasks.dcr_assemble_coadd Module

Classes

DcrAssembleCoaddConnections(*[, config])
DcrAssembleCoaddTask(*args, **kwargs)	Assemble DCR coadded images from a set of warps.
DcrAssembleCoaddConfig(*args, **kw)

lsst.drp.tasks.forcedPhotCoadd Module

Classes

ForcedPhotCoaddConfig(*args, **kw)
ForcedPhotCoaddTask([refSchema, initInputs])	A pipeline task for performing forced measurement on coadd images.

lsst.drp.tasks.gbdesAstrometricFit Module

Functions

calculate_apparent_motion(catalog, refEpoch)

Calculate shift from reference epoch to the apparent observed position at another date.

Classes

GbdesAstrometricFitConnections(*[, config])	Middleware input/output connections for task data.
GbdesAstrometricFitConfig(*args, **kw)	Configuration for GbdesAstrometricFitTask
GbdesAstrometricFitTask(**kwargs)	Calibrate the WCS across multiple visits of the same field using the GBDES package.
GbdesAstrometricMultibandFitConnections(*[, ...])
GbdesAstrometricMultibandFitTask(**kwargs)	Calibrate the WCS across multiple visits in multiple filters of the same field using the GBDES package.
GbdesGlobalAstrometricFitConnections(*[, config])
GbdesGlobalAstrometricFitConfig(*args, **kw)
GbdesGlobalAstrometricFitTask(**kwargs)	Calibrate the WCS across multiple visits and multiple fields using the GBDES package.
GbdesGlobalAstrometricMultibandFitConnections(*)
GbdesGlobalAstrometricMultibandFitTask(**kwargs)	Calibrate the WCS across multiple visits in multiple filters and multiple fields using the GBDES package.

lsst.drp.tasks.make_direct_warp Module

Classes

MakeDirectWarpConfig(*args, **kw)	Configuration for the MakeDirectWarpTask.
MakeDirectWarpTask(**kwargs)	Warp single-detector images onto a common projection.

lsst.drp.tasks.make_psf_matched_warp Module

Classes

MakePsfMatchedWarpConfig(*args, **kw)	Config for MakePsfMatchedWarpTask.
MakePsfMatchedWarpConnections(*[, config])	Connections for MakePsfMatchedWarpTask
MakePsfMatchedWarpTask(**kwargs)

lsst.drp.tasks.reprocess_visit_image Module

Functions

combine_backgrounds(initial_pvi_background, ...)

Return the total background that was applied to the original processing.

Classes

ReprocessVisitImageTask([schema])	Use the visit-level calibrations to perform detection and measurement on the single frame exposures and produce a "final" exposure and catalog.
ReprocessVisitImageConfig(*args, **kw)

lsst.drp.tasks.update_visit_summary Module

Classes

UpdateVisitSummaryConnections(*[, config])
UpdateVisitSummaryConfig(*args, **kw)	Configuration for UpdateVisitSummaryTask.
UpdateVisitSummaryTask(*[, initInputs])	A pipeline task that creates a new visit-summary table after all lsst.afw.image.Exposure components have been finalized.
PossiblyMultipleInput()	A helper ABC for handling input ExposureCatalog datasets that may be multiple (one per tract/visit combination) or unique/global (one per visit).
PerTractInput(catalogs_by_tract)	Wrapper class for input ExposureCatalog datasets that are per-tract.
GlobalInput(catalog)	Wrapper class for input ExposureCatalog datasets that are not per-tract.