Modify ap_pipe call for association.

Comment out diaForcedSourceTask for now. Fix ticket number in TODO.
lsst · Jun 7, 2019 · 7feff2d · 7feff2d
1 parent 1054f17
commit 7feff2d
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/python/lsst/ap/pipe/ap_pipe.py b/python/lsst/ap/pipe/ap_pipe.py
@@ -300,12 +300,17 @@ def runAssociation(self, sensorRef):
         catalog = sensorRef.get(diffType + "Diff_diaSrc")
         diffim = sensorRef.get(diffType + "Diff_differenceExp")
 
-        dia_sources = self.diaSourceDpddifier.run(catalog, diffim)
+        dia_sources = self.diaSourceDpddifier.run(catalog,
+                                                  diffim,
+                                                  return_pandas=True)
         result = self.associator.run(dia_sources, diffim, self.ppdb)
-        self.diaForcedSource.run(result.dia_objects,
-                                 sensorRef.get("ccdExposureId_bits"),
-                                 sensorRef.get("calexp"),
-                                 diffim)
+        # TODO: DM-19906
+        #    Need to convert diaFourcedSource task to accept pandas.DataFrame
+        #    as an input.
+        # self.diaForcedSource.run(result.dia_objects,
+        #                          sensorRef.get("ccdExposureId_bits"),
+        #                          sensorRef.get("calexp"),
+        #                          diffim)
 
         return pipeBase.Struct(
             l1Database=self.ppdb,