From 242ff6a6f4423d89159214f2542d160496ad6cdb Mon Sep 17 00:00:00 2001
From: Saarah Hall <66533667+saarahhall@users.noreply.github.com>
Date: Fri, 4 Aug 2023 16:05:07 -0500
Subject: [PATCH] sedmv2 realtime (#585)

---
 mirar/pipelines/sedmv2/blocks.py          | 14 ++++++++++++++
 mirar/pipelines/sedmv2/sedmv2_pipeline.py |  2 ++
 2 files changed, 16 insertions(+)

diff --git a/mirar/pipelines/sedmv2/blocks.py b/mirar/pipelines/sedmv2/blocks.py
index ba7cabd3a..5666bab0c 100644
--- a/mirar/pipelines/sedmv2/blocks.py
+++ b/mirar/pipelines/sedmv2/blocks.py
@@ -221,3 +221,17 @@
 ]
 
 imsub = subtract  # + export_diff_to_db + extract_candidates
+
+
+detrend_only = [
+    MaskPixelsFromPath(mask_path=sedmv2_mask_path),
+    BiasCalibrator(),
+    ImageSelector((OBSCLASS_KEY, ["flat", "science"])),
+    ImageBatcher(
+        split_key="filterid"
+    ),  # maybe change back to filter after revising load func
+    FlatCalibrator(),
+    ImageBatcher(split_key=BASE_NAME_KEY),
+    ImageSelector((OBSCLASS_KEY, ["science"])),  # pylint: disable=duplicate-code
+    ImageSaver(output_dir_name="detrend", write_mask=True),
+]
diff --git a/mirar/pipelines/sedmv2/sedmv2_pipeline.py b/mirar/pipelines/sedmv2/sedmv2_pipeline.py
index ee514e7df..5fee08412 100644
--- a/mirar/pipelines/sedmv2/sedmv2_pipeline.py
+++ b/mirar/pipelines/sedmv2/sedmv2_pipeline.py
@@ -10,6 +10,7 @@
 from mirar.io import open_mef_image
 from mirar.pipelines.base_pipeline import Pipeline
 from mirar.pipelines.sedmv2.blocks import (
+    detrend_only,
     image_photometry,
     load_raw,
     process_stellar,
@@ -36,6 +37,7 @@ class SEDMv2Pipeline(Pipeline):
         "default": load_raw + process_stellar,
         "default_stellar": load_raw + process_stellar + image_photometry,
         "default_transient": load_raw + process_transient,  # +imsub,
+        "realtime": load_raw + detrend_only,  # +much more...
     }
 
     @staticmethod