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#

Contributing#

lsst.drp.tasks is developed at 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.

PerHealpixInput(catalogs_by_pixel)

Wrapper class for input ExposureCatalog datasets that are per-healpix pixel.

GlobalInput(catalog)

Wrapper class for input ExposureCatalog datasets that are not per-tract.