Merge pull request #110 from lsst/tickets/DM-40322

DM-40322: Implement new connections hook for refcat lookups.
lsst · Aug 8, 2023 · 98cecbd · 98cecbd
2 parents cee6e8c + ab2a956
commit 98cecbd
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 0 deletions.
diff --git a/python/lsst/fgcmcal/fgcmBuildFromIsolatedStars.py b/python/lsst/fgcmcal/fgcmBuildFromIsolatedStars.py
@@ -138,6 +138,9 @@ def __init__(self, *, config=None):
             self.prerequisiteInputs.remove("fgcm_lookup_table")
             self.outputs.remove("fgcm_reference_stars")
 
+    def getSpatialBoundsConnections(self):
+        return ("isolated_star_cats", "visit_summaries")
+
 
 class FgcmBuildFromIsolatedStarsConfig(FgcmBuildStarsConfigBase, pipeBase.PipelineTaskConfig,
                                        pipelineConnections=FgcmBuildFromIsolatedStarsConnections):

diff --git a/python/lsst/fgcmcal/fgcmBuildStarsTable.py b/python/lsst/fgcmcal/fgcmBuildStarsTable.py
@@ -149,6 +149,9 @@ def __init__(self, *, config=None):
         if not config.doReferenceMatches:
             self.outputs.remove("fgcmReferenceStars")
 
+    def getSpatialBoundsConnections(self):
+        return ("visitSummary",)
+
 
 class FgcmBuildStarsTableConfig(FgcmBuildStarsConfigBase, pipeBase.PipelineTaskConfig,
                                 pipelineConnections=FgcmBuildStarsTableConnections):

diff --git a/python/lsst/fgcmcal/fgcmCalibrateTractTable.py b/python/lsst/fgcmcal/fgcmCalibrateTractTable.py
@@ -135,6 +135,9 @@ def __init__(self, *, config=None):
         if not config.fgcmOutputProducts.doZeropointOutput:
             self.prerequisiteInputs.remove("fgcmZeropoints")
 
+    def getSpatialBoundsConnections(self):
+        return ("visitSummary",)
+
 
 class FgcmCalibrateTractTableConfig(FgcmCalibrateTractConfigBase, pipeBase.PipelineTaskConfig,
                                     pipelineConnections=FgcmCalibrateTractTableConnections):

diff --git a/python/lsst/fgcmcal/fgcmOutputProducts.py b/python/lsst/fgcmcal/fgcmOutputProducts.py
@@ -163,6 +163,9 @@ def __init__(self, *, config=None):
         if not config.doReferenceCalibration:
             self.outputs.remove("fgcmOffsets")
 
+    def getSpatialBoundsConnections(self):
+        return ("fgcmPhotoCalib",)
+
 
 class FgcmOutputProductsConfig(pipeBase.PipelineTaskConfig,
                                pipelineConnections=FgcmOutputProductsConnections):