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.