CalibrateTask¶
-
class
lsst.pipe.tasks.calibrate.CalibrateTask(butler=None, astromRefObjLoader=None, photoRefObjLoader=None, icSourceSchema=None, initInputs=None, **kwargs)¶ Bases:
lsst.pipe.base.PipelineTaskCalibrate an exposure: measure sources and perform astrometric and photometric calibration.
Given an exposure with a good PSF model and aperture correction map(e.g. as provided by
CharacterizeImageTask), perform the following operations: - Run detection and measurement - Run astrometry subtask to fit an improved WCS - Run photoCal subtask to fit the exposure’s photometric zero-pointParameters: - butler :
None Compatibility parameter. Should always be
None.- astromRefObjLoader :
lsst.meas.algorithms.ReferenceObjectLoader, optional Unused in gen3: must be
None.- photoRefObjLoader :
lsst.meas.algorithms.ReferenceObjectLoader, optional Unused in gen3: must be
None.- icSourceSchema :
lsst.afw.table.Schema, optional Schema for the icSource catalog.
- initInputs :
dict, optional Dictionary that can contain a key
icSourceSchemacontaining the input schema. If present will override the value oficSourceSchema.
Raises: - RuntimeError
Raised if any of the following occur: - isSourceCat is missing fields specified in icSourceFieldsToCopy. - PipelineTask form of this task is initialized with reference object
loaders.
Notes
Quantities set in exposure Metadata:
- MAGZERO_RMS
- MAGZERO’s RMS == sigma reported by photoCal task
- MAGZERO_NOBJ
- Number of stars used == ngood reported by photoCal task
- COLORTERM1
- ?? (always 0.0)
- COLORTERM2
- ?? (always 0.0)
- COLORTERM3
- ?? (always 0.0)
Debugging: CalibrateTask has a debug dictionary containing one key:
- calibrate
- frame (an int; <= 0 to not display) in which to display the exposure, sources and matches. See @ref lsst.meas.astrom.displayAstrometry for the meaning of the various symbols.
Attributes Summary
canMultiprocessMethods Summary
copyIcSourceFields(icSourceCat, sourceCat)Match sources in an icSourceCat and a sourceCat and copy fields. emptyMetadata()Empty (clear) the metadata for this Task and all sub-Tasks. getAllSchemaCatalogs()Get schema catalogs for all tasks in the hierarchy, combining the results into a single dict. getFullMetadata()Get metadata for all tasks. getFullName()Get the task name as a hierarchical name including parent task names. getName()Get the name of the task. getResourceConfig()Return resource configuration for this task. getSchemaCatalogs()Return a dict of empty catalogs for each catalog dataset produced by this task. getTaskDict()Get a dictionary of all tasks as a shallow copy. makeField(doc)Make a lsst.pex.config.ConfigurableFieldfor this task.makeSubtask(name, **keyArgs)Create a subtask as a new instance as the nameattribute of this task.run(exposure[, exposureIdInfo, background, …])Calibrate an exposure. runQuantum(butlerQC, inputRefs, outputRefs)Method to do butler IO and or transforms to provide in memory objects for tasks run method setMetadata(exposure[, photoRes])Set task and exposure metadata. timer(name, logLevel)Context manager to log performance data for an arbitrary block of code. Attributes Documentation
-
canMultiprocess= True¶
Methods Documentation
-
copyIcSourceFields(icSourceCat, sourceCat)¶ Match sources in an icSourceCat and a sourceCat and copy fields.
The fields copied are those specified by
config.icSourceFieldsToCopy.Parameters: - icSourceCat :
lsst.afw.table.SourceCatalog Catalog from which to copy fields.
- sourceCat :
lsst.afw.table.SourceCatalog Catalog to which to copy fields.
Raises: - RuntimeError
Raised if any of the following occur: - icSourceSchema and icSourceKeys are not specified. - icSourceCat and sourceCat are not specified. - icSourceFieldsToCopy is empty.
- icSourceCat :
-
emptyMetadata() → None¶ Empty (clear) the metadata for this Task and all sub-Tasks.
-
getAllSchemaCatalogs() → Dict[str, Any]¶ Get schema catalogs for all tasks in the hierarchy, combining the results into a single dict.
Returns: - schemacatalogs :
dict Keys are butler dataset type, values are a empty catalog (an instance of the appropriate
lsst.afw.tableCatalog type) for all tasks in the hierarchy, from the top-level task down through all subtasks.
Notes
This method may be called on any task in the hierarchy; it will return the same answer, regardless.
The default implementation should always suffice. If your subtask uses schemas the override
Task.getSchemaCatalogs, not this method.- schemacatalogs :
-
getFullMetadata() → lsst.pipe.base._task_metadata.TaskMetadata¶ Get metadata for all tasks.
Returns: - metadata :
TaskMetadata The keys are the full task name. Values are metadata for the top-level task and all subtasks, sub-subtasks, etc.
Notes
The returned metadata includes timing information (if
@timer.timeMethodis used) and any metadata set by the task. The name of each item consists of the full task name with.replaced by:, followed by.and the name of the item, e.g.:topLevelTaskName:subtaskName:subsubtaskName.itemName
using
:in the full task name disambiguates the rare situation that a task has a subtask and a metadata item with the same name.- metadata :
-
getFullName() → str¶ Get the task name as a hierarchical name including parent task names.
Returns: - fullName :
str The full name consists of the name of the parent task and each subtask separated by periods. For example:
- The full name of top-level task “top” is simply “top”.
- The full name of subtask “sub” of top-level task “top” is “top.sub”.
- The full name of subtask “sub2” of subtask “sub” of top-level task “top” is “top.sub.sub2”.
- fullName :
-
getResourceConfig() → Optional[ResourceConfig]¶ Return resource configuration for this task.
Returns: - Object of type
ResourceConfigorNoneif resource - configuration is not defined for this task.
- Object of type
-
getSchemaCatalogs()¶ Return a dict of empty catalogs for each catalog dataset produced by this task.
-
getTaskDict() → Dict[str, weakref]¶ Get a dictionary of all tasks as a shallow copy.
Returns: - taskDict :
dict Dictionary containing full task name: task object for the top-level task and all subtasks, sub-subtasks, etc.
- taskDict :
-
classmethod
makeField(doc: str) → lsst.pex.config.configurableField.ConfigurableField¶ Make a
lsst.pex.config.ConfigurableFieldfor this task.Parameters: - doc :
str Help text for the field.
Returns: - configurableField :
lsst.pex.config.ConfigurableField A
ConfigurableFieldfor this task.
Examples
Provides a convenient way to specify this task is a subtask of another task.
Here is an example of use:
class OtherTaskConfig(lsst.pex.config.Config): aSubtask = ATaskClass.makeField("brief description of task")
- doc :
-
makeSubtask(name: str, **keyArgs) → None¶ Create a subtask as a new instance as the
nameattribute of this task.Parameters: - name :
str Brief name of the subtask.
- keyArgs
Extra keyword arguments used to construct the task. The following arguments are automatically provided and cannot be overridden:
- “config”.
- “parentTask”.
Notes
The subtask must be defined by
Task.config.name, an instance ofConfigurableFieldorRegistryField.- name :
-
run(exposure, exposureIdInfo=None, background=None, icSourceCat=None)¶ Calibrate an exposure.
Parameters: - exposure :
lsst.afw.image.ExposureF Exposure to calibrate.
- exposureIdInfo :
lsst.obs.baseExposureIdInfo, optional Exposure ID info. If not provided, returned SourceCatalog IDs will not be globally unique.
- background :
lsst.afw.math.BackgroundList, optional Initial model of background already subtracted from exposure.
- icSourceCat :
lsst.afw.image.SourceCatalog, optional SourceCatalog from CharacterizeImageTask from which we can copy some fields.
Returns: - result :
lsst.pipe.base.Struct Results as a struct with attributes:
exposureCharacterized exposure (
lsst.afw.image.ExposureF).sourceCatDetected sources (
lsst.afw.table.SourceCatalog).outputBackgroundModel of subtracted background (
lsst.afw.math.BackgroundList).astromMatchesList of source/ref matches from astrometry solver.
matchMetaMetadata from astrometry matches.
outputExposureAnother reference to
exposurefor compatibility.outputCatAnother reference to
sourceCatfor compatibility.
- exposure :
-
runQuantum(butlerQC, inputRefs, outputRefs)¶ Method to do butler IO and or transforms to provide in memory objects for tasks run method
Parameters: - butlerQC :
ButlerQuantumContext A butler which is specialized to operate in the context of a
lsst.daf.butler.Quantum.- inputRefs :
InputQuantizedConnection Datastructure whose attribute names are the names that identify connections defined in corresponding
PipelineTaskConnectionsclass. The values of these attributes are thelsst.daf.butler.DatasetRefobjects associated with the defined input/prerequisite connections.- outputRefs :
OutputQuantizedConnection Datastructure whose attribute names are the names that identify connections defined in corresponding
PipelineTaskConnectionsclass. The values of these attributes are thelsst.daf.butler.DatasetRefobjects associated with the defined output connections.
- butlerQC :
-
setMetadata(exposure, photoRes=None)¶ Set task and exposure metadata.
Logs a warning continues if needed data is missing.
Parameters: - exposure :
lsst.afw.image.ExposureF Exposure to set metadata on.
- photoRes :
lsst.pipe.base.Struct, optional Result of running photoCal task.
- exposure :
-
timer(name: str, logLevel: int = 10) → Iterator[None]¶ Context manager to log performance data for an arbitrary block of code.
Parameters: See also
timer.logInfo
Examples
Creating a timer context:
with self.timer("someCodeToTime"): pass # code to time
- butler :