From 19f0ab6a24de1562cc4a71b5d8bc5f822b87ad06 Mon Sep 17 00:00:00 2001 From: Hsin-Fang Chiang Date: Tue, 3 Nov 2026 16:53:26 -0800 Subject: [PATCH] Add makeVisitTable task --- bps/clustering/clustering_Daytime.yaml | 2 +- pipelines/_ingredients/ApPipe.yaml | 10 ++++++++++ pipelines/_ingredients/ApPipeWithPreconvolution.yaml | 4 ++++ 3 files changed, 15 insertions(+), 1 deletion(-) diff --git a/bps/clustering/clustering_Daytime.yaml b/bps/clustering/clustering_Daytime.yaml index 12ba2c85..0c981f4a 100644 --- a/bps/clustering/clustering_Daytime.yaml +++ b/bps/clustering/clustering_Daytime.yaml @@ -41,7 +41,7 @@ cluster: pipetasks: makeSampledImageSubtractionMetrics,analyzeSampledImageSubtractionMetrics dimensions: visit,detector consolidateVisit: - pipetasks: consolidateVisitSummary,consolidateDiaSourceTable,analyzeVisitSampledImageSubtractionMetrics,consolidatePromptSource,splitPromptSource + pipetasks: consolidateVisitSummary,makeVisitTable,consolidateDiaSourceTable,analyzeVisitSampledImageSubtractionMetrics,consolidatePromptSource,splitPromptSource dimensions: visit diff --git a/pipelines/_ingredients/ApPipe.yaml b/pipelines/_ingredients/ApPipe.yaml index 3a586aed..5112dd3c 100644 --- a/pipelines/_ingredients/ApPipe.yaml +++ b/pipelines/_ingredients/ApPipe.yaml @@ -209,6 +209,11 @@ tasks: connections.visitSummary: visit_summary connections.visitSummarySchema: visit_summary_schema input_image_type: parameters.image_type + makeVisitTable: + class: lsst.pipe.tasks.postprocess.MakeVisitTableTask + config: + connections.visitSummaries: visit_summary + connections.outputCatalog: visit_table standardizePromptSource: class: lsst.pipe.tasks.postprocess.TransformSourceTableTask config: @@ -267,6 +272,7 @@ subsets: - analyzeSampledImageSubtractionMetrics - analyzePreliminarySummaryStats - consolidateVisitSummary + - makeVisitTable - consolidateDiaSourceTable - analyzeVisitSampledImageSubtractionMetrics - aggregateVisitSummary @@ -309,6 +315,7 @@ subsets: afterburner: subset: - consolidateVisitSummary + - makeVisitTable - consolidateDiaSourceTable - makeSampledImageSubtractionMetrics - analyzeSampledImageSubtractionMetrics @@ -432,3 +439,6 @@ contracts: - contract: consolidateDiaSourceTable.connections.ConnectionsClass(config=consolidateDiaSourceTable).inputCatalogs.name == standardizeDiaSource.connections.ConnectionsClass(config=standardizeDiaSource).diaSourceTable.name msg: "consolidateDiaSourceTable.inputCatalogs != standardizeDiaSource.diaSourceTable" + - contract: consolidateVisitSummary.connections.ConnectionsClass(config=consolidateVisitSummary).visitSummary.name == + makeVisitTable.connections.ConnectionsClass(config=makeVisitTable).visitSummaries.name + msg: "consolidateVisitSummary.visitSummary != makeVisitTable.visitSummaries" diff --git a/pipelines/_ingredients/ApPipeWithPreconvolution.yaml b/pipelines/_ingredients/ApPipeWithPreconvolution.yaml index 82b7a33e..e57987da 100644 --- a/pipelines/_ingredients/ApPipeWithPreconvolution.yaml +++ b/pipelines/_ingredients/ApPipeWithPreconvolution.yaml @@ -67,6 +67,7 @@ subsets: - analyzeSampledImageSubtractionMetrics - analyzePreliminarySummaryStats - consolidateVisitSummary + - makeVisitTable - consolidateDiaSourceTable - analyzeVisitSampledImageSubtractionMetrics - aggregateVisitSummary @@ -130,3 +131,6 @@ contracts: - contract: subtractImagesScore.connections.ConnectionsClass(config=subtractImagesScore).scoreExposure.name == detectAndMeasureDiaSource.connections.ConnectionsClass(config=detectAndMeasureDiaSource).scoreExposure.name msg: "subtractImagesScore.scoreExposure != detectAndMeasureDiaSource.scoreExposure" + - contract: consolidateVisitSummary.connections.ConnectionsClass(config=consolidateVisitSummary).visitSummary.name == + makeVisitTable.connections.ConnectionsClass(config=makeVisitTable).visitSummaries.name + msg: "consolidateVisitSummary.visitSummary != makeVisitTable.visitSummaries"