Skip to content

Commit

Permalink
Merge branch 'tickets/DM-38619'
Browse files Browse the repository at this point in the history
  • Loading branch information
taranu committed Jul 13, 2023
2 parents 577b017 + 0f8b162 commit 621ab29
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion python/lsst/pipe/tasks/fit_coadd_multiband.py
Original file line number Diff line number Diff line change
Expand Up @@ -277,7 +277,7 @@ def __init__(self, initInputs, **kwargs):

def runQuantum(self, butlerQC, inputRefs, outputRefs):
inputs = butlerQC.get(inputRefs)
id_tp = self.config.id_generator.apply(butlerQC.quantum.dataId).catalog_id
id_tp = self.config.idGenerator.apply(butlerQC.quantum.dataId).catalog_id
# This is a roundabout way of ensuring all inputs get sorted and matched
input_refs_objs = [(getattr(inputRefs, key), inputs[key])
for key in ("cats_meas", "coadds", "models_psf")]
Expand Down
4 changes: 2 additions & 2 deletions python/lsst/pipe/tasks/fit_coadd_psf.py
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ def get_psf_image(self, source):

class CoaddPsfFitConnections(
pipeBase.PipelineTaskConnections,
dimensions=("tract", "patch", "skymap"),
dimensions=("tract", "patch", "band", "skymap"),
defaultTemplates=CoaddPsfFitBaseTemplates,
):
coadd = cT.Input(
Expand Down Expand Up @@ -158,7 +158,7 @@ def __init__(self, initInputs, **kwargs):

def runQuantum(self, butlerQC, inputRefs, outputRefs):
inputs = butlerQC.get(inputRefs)
id_tp = self.config.id_generator.apply(butlerQC.quantum.dataId).catalog_id
id_tp = self.config.idGenerator.apply(butlerQC.quantum.dataId).catalog_id
dataId = inputRefs.cat_meas.dataId
for dataRef in (inputRefs.coadd,):
if dataRef.dataId != dataId:
Expand Down

0 comments on commit 621ab29

Please sign in to comment.