Add runtime metrics for FilterDiaSourceCatalogTask

pipelines/_ingredients/MetricsRuntime.yaml

@@ -119,6 +119,13 @@ tasks:
       connections.metric: PackageAlertsTime
       connections.labelName: diaPipe
       target: diaPipe:alertPackager.run
+  timing_filterDiaSrcCat:
+    class: lsst.verify.tasks.commonMetrics.TimingMetricTask
+    config:
+      connections.package: ap_association
+      connections.metric: FilterDiaSourceCatalogTime
+      connections.labelName: filterDiaSrcCat
+      target: filterDiaSrcCat.run
   cputiming_isr:
     class: lsst.verify.tasks.commonMetrics.CpuTimingMetricTask
     config:
@@ -233,6 +240,13 @@ tasks:
       connections.metric: PackageAlertsCpuTime
       connections.labelName: diaPipe
       target: diaPipe:alertPackager.run
+  cputiming_filterDiaSrcCat:
+    class: lsst.verify.tasks.commonMetrics.TimingMetricTask
+    config:
+      connections.package: ap_association
+      connections.metric: FilterDiaSourceCatalogCpuTime
+      connections.labelName: filterDiaSrcCat
+      target: filterDiaSrcCat.run
   memory_apPipe:
     class: lsst.verify.tasks.commonMetrics.MemoryMetricTask
     config:
@@ -253,4 +267,4 @@ tasks:
       connections.package: ap_association
       connections.metric: PackageAlertsMemory
       connections.labelName: diaPipe
-      target: diaPipe:alertPackager.run
+      target: diaPipe:alertPackager.run

python/lsst/ap/verify/testPipeline.py

@@ -433,6 +433,30 @@ def run(self, science, matchedTemplate, difference,
                       )
 
 
+class MockFilterDiaSourceCatalogTask(PipelineTask):
+    """A do-nothing substitute for FilterDiaSourceCatalogTask.
+    """
+    ConfigClass = FilterDiaSourceCatalogConfig
+    _DefaultName = "notFilterDiaSourceCatalog"
+
+    def run(self, diaSourceCat):
+        """Produce filtering outputs with no processing.
+
+        Parameters
+        ----------
+        diaSourceCat : `lsst.afw.table.SourceCatalog`
+            Catalog of sources measured on the difference image.
+
+        Returns
+        -------
+        results : `lsst.pipe.base.Struct`
+            Results struct with components.
+        """
+        return pipeBase.Struct(filteredDiaSourceCat=afwTable.SourceCatalog(),
+                               rejectedDiaSources=afwTable.SourceCatalog(),
+                               )
+
+
 class MockTransformDiaSourceCatalogTask(PipelineTask):
     """A do-nothing substitute for TransformDiaSourceCatalogTask.
     """