Add specification for ForcedSource Table

lsst · Sep 9, 2021 · 5ada575 · 5ada575
1 parent e5ac33f
commit 5ada575
Show file tree

Hide file tree

Showing 3 changed files with 92 additions and 0 deletions.
diff --git a/config/imsim/transformForcedSourceTable.py b/config/imsim/transformForcedSourceTable.py
@@ -0,0 +1,5 @@
+import os
+
+# Use the environment variable to prevent hardcoding of paths
+# into quantum graphs.
+config.functorFile = os.path.join('$OBS_LSST_DIR', 'policy', 'imsim', 'ForcedSource.yaml')
diff --git a/pipelines/imsim/DRP.yaml b/pipelines/imsim/DRP.yaml
@@ -100,6 +100,7 @@ subsets:
         - getTemplate
         - imageDifference
         - transformDiaSourceCat
+        - writeForcedSourceTable
         description: >
             Tasks that can be run together, but only after the 'step1', 'step2'
             and 'step3' subsets
@@ -112,6 +113,7 @@ subsets:
         subset:
         - drpAssociation
         - drpDiaCalculation
+        - transformForcedSourceTable
         description: >
             Tasks that can be run together, but only after the 'step1', 'step2',
             'step3', and 'step4' subsets
@@ -123,6 +125,7 @@ subsets:
     step6:
         subset:
         - consolidateDiaSourceTable
+        - consolidateForcedSourceTable
         description: >
             Tasks that can be run together, but only after the 'step1', 'step2',
             'step3', and 'step4' subsets

diff --git a/policy/imsim/ForcedSource.yaml b/policy/imsim/ForcedSource.yaml
@@ -0,0 +1,84 @@
+funcs:
+    objectId:
+        functor: Column
+        args: objectId
+        dataset: calexp
+    parentObjectId:
+        functor: Column
+        args: parent
+        dataset: calexp
+    coord_ra:
+        # reference position for ObjectId. Required by databse. Not in DPDD
+        functor: CoordColumn
+        dataset: calexp
+        args: coord_ra
+    coord_dec:
+         # reference position for ObjectId. Required by databse. Not in DPDD
+        functor: CoordColumn
+        dataset: calexp
+        args: coord_dec
+    ccdVisitId:
+        functor: Column
+        dataset: calexp
+        args: ccdVisitId
+    band:
+        functor: Column
+        dataset: calexp
+        args: band
+    PsFlux:
+        functor: LocalNanojansky
+        dataset: calexp
+        args:
+            - base_PsfFlux_instFlux
+            - base_PsfFlux_instFluxErr
+            - base_LocalPhotoCalib
+            - base_LocalPhotoCalibErr
+    PsFluxErr:
+        functor: LocalNanojanskyErr
+        dataset: calexp
+        args:
+            - base_PsfFlux_instFlux
+            - base_PsfFlux_instFluxErr
+            - base_LocalPhotoCalib
+            - base_LocalPhotoCalibErr
+    PsFluxFlag:
+        functor: Column
+        dataset: calexp
+        args: base_PsfFlux_flag
+    psFluxApCorr:
+        functor: Column
+        dataset: calexp
+        args: base_PsfFlux_apCorr
+    psFluxApCorrErr:
+        functor: Column
+        dataset: calexp
+        args: base_PsfFlux_apCorrErr
+    PsDiffFlux:
+        functor: LocalNanojansky
+        dataset: diff
+        args:
+            - base_PsfFlux_instFlux
+            - base_PsfFlux_instFluxErr
+            - base_LocalPhotoCalib
+            - base_LocalPhotoCalibErr
+    PsDiffFluxErr:
+        functor: LocalNanojanskyErr
+        dataset: diff
+        args:
+            - base_PsfFlux_instFlux
+            - base_PsfFlux_instFluxErr
+            - base_LocalPhotoCalib
+            - base_LocalPhotoCalibErr
+    PsDiffFluxFlag:
+        functor: Column
+        dataset: diff
+        args: base_PsfFlux_flag
+    psDiffFluxApCorr:
+        functor: Column
+        dataset: diff
+        args: base_PsfFlux_apCorr
+    psDiffFluxApCorrErr:
+        functor: Column
+        dataset: diff
+        args: base_PsfFlux_apCorrErr
+# PixelFlags exist in the forced_src and the forced_diff dataset, but they're all False