Remove longTrailedSources from pipeline output

lsst · Apr 19, 2024 · aae5785 · aae5785
1 parent ad424c6
commit aae5785
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 5 deletions.
diff --git a/python/lsst/ap/verify/testPipeline.py b/python/lsst/ap/verify/testPipeline.py
@@ -457,6 +457,7 @@ def run(self, diaSourceCat):
         """
         return Struct(filteredDiaSourceCat=afwTable.SourceCatalog(),
                       rejectedDiaSources=afwTable.SourceCatalog(),
+                      longTrailedSources=afwTable.SourceCatalog(),
                       )
 
 
@@ -631,6 +632,4 @@ def run(self,
         return Struct(apdbMarker=self.config.apdb.value,
                       associatedDiaSources=pandas.DataFrame(),
                       diaForcedSources=pandas.DataFrame(),
-                      diaObjects=pandas.DataFrame(),
-                      longTrailedSources=pandas.DataFrame(),
-                      )
+                      diaObjects=pandas.DataFrame(),)
diff --git a/tests/test_testPipeline.py b/tests/test_testPipeline.py
@@ -131,7 +131,8 @@ def setUpClass(cls):
         butlerTests.addDatasetType(cls.repo, "visitSsObjects", cls.visitOnlyId.dimensions, "DataFrame")
         butlerTests.addDatasetType(cls.repo, "apdb_marker", cls.visitId.dimensions, "Config")
         butlerTests.addDatasetType(cls.repo, "deepDiff_assocDiaSrc", cls.visitId.dimensions, "DataFrame")
-        butlerTests.addDatasetType(cls.repo, "deepDiff_longTrailedSrc", cls.visitId.dimensions, "DataFrame")
+        butlerTests.addDatasetType(cls.repo, "deepDiff_longTrailedSrc", cls.visitId.dimensions,
+                                   "ArrowAstropy")
         butlerTests.addDatasetType(cls.repo, "deepRealBogusSources", cls.visitId.dimensions, "Catalog")
         butlerTests.addDatasetType(cls.repo, "deepDiff_diaForcedSrc", cls.visitId.dimensions, "DataFrame")
         butlerTests.addDatasetType(cls.repo, "deepDiff_diaObject", cls.visitId.dimensions, "DataFrame")
@@ -358,7 +359,6 @@ def testMockDiaPipelineTask(self):
              "template": self.visitId,
              "apdbMarker": self.visitId,
              "associatedDiaSources": self.visitId,
-             "longTrailedSources": self.visitId,
              "diaForcedSources": self.visitId,
              "diaObjects": self.visitId,
              })