Skip to content

Commit 522d39f

Browse files
committed
Update connections
1 parent 3ba4abc commit 522d39f

File tree

2 files changed

+30
-3
lines changed

2 files changed

+30
-3
lines changed

python/lsst/pipe/tasks/dcr_multiBand.py

Lines changed: 29 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -235,8 +235,8 @@ class DcrMeasureMergedCoaddSourcesConnections(
235235
inputSchema = cT.InitInput(
236236
doc="Input schema for measure merged task produced by a deblender or detection task",
237237
name="deepCoadd_deblendedFlux_schema",
238-
storageClass="SourceCatalog"
239-
# dimensions=("tract", "patch", "band", "skymap")
238+
storageClass="SourceCatalog",
239+
dimensions=("tract", "patch", "band", "skymap")
240240
)
241241
outputSchema = cT.InitOutput(
242242
doc="Output schema after all new fields are added by task",
@@ -249,6 +249,33 @@ class DcrMeasureMergedCoaddSourcesConnections(
249249
storageClass="ExposureF",
250250
dimensions=("tract", "patch", "band", "subfilter", "skymap")
251251
)
252+
sourceTableHandles = cT.Input(
253+
doc=("Source tables that are derived from the ``CalibrateTask`` sources. "
254+
"These tables contain astrometry and photometry flags, and optionally "
255+
"PSF flags."),
256+
name="sourceTable_visit",
257+
storageClass="ArrowAstropy",
258+
dimensions=("instrument", "visit"),
259+
multiple=True,
260+
deferLoad=True,
261+
)
262+
finalizedSourceTableHandles = cT.Input(
263+
doc=("Finalized source tables from ``FinalizeCalibrationTask``. These "
264+
"tables contain PSF flags from the finalized PSF estimation."),
265+
name="finalized_src_table",
266+
storageClass="ArrowAstropy",
267+
dimensions=("instrument", "visit"),
268+
multiple=True,
269+
deferLoad=True,
270+
)
271+
finalVisitSummaryHandles = cT.Input(
272+
doc="Final visit summary table",
273+
name="finalVisitSummary",
274+
storageClass="ExposureCatalog",
275+
dimensions=("instrument", "visit"),
276+
multiple=True,
277+
deferLoad=True,
278+
)
252279
inputCatalog = cT.Input(
253280
doc=("Name of the input catalog to use."
254281
"If the single band deblender was used this should be 'deblendedFlux."

python/lsst/pipe/tasks/mergeDetections.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
# You should have received a copy of the GNU General Public License
2020
# along with this program. If not, see <https://www.gnu.org/licenses/>.
2121

22-
__all__ = ["MergeDetectionsConfig", "MergeDetectionsTask", "MergeDetectionsConnections"]
22+
__all__ = ["MergeDetectionsConfig", "MergeDetectionsTask"]
2323

2424
import numpy as np
2525
from numpy.lib.recfunctions import rec_join

0 commit comments

Comments
 (0)