Pass through compressed_slc_plan config to sequential

src/dolphin/workflows/wrapped_phase.py

@@ -197,6 +197,7 @@ def run(
             cslc_date_fmt=cfg.input_options.cslc_date_fmt,
             block_shape=cfg.worker_settings.block_shape,
             baseline_lag=cfg.phase_linking.baseline_lag,
+            compressed_slc_plan=cfg.phase_linking.compressed_slc_plan,
             **kwargs,
         )
     # Dump the used options for JSON parsing

tests/test_stack.py

@@ -262,3 +262,35 @@ def test_compressed_idx_setting(slc_file_list, slc_date_list, is_compressed):
     assert ministacks[0].compressed_reference_date == expected_ref_date
     # But, the output reference date should be the first one (since it was unset)
     assert ministacks[0].output_reference_date == slc_date_list[0]
+
+
+@pytest.mark.parametrize(
+    "plan", ["always_first", "first_per_ministack", "last_per_ministack"]
+)
+def test_compressed_plans(slc_file_list, slc_date_list, is_compressed, plan):
+    """Check the planning works to set a manually passed compressed index."""
+    is_compressed = [False] * len(slc_file_list)
+    ministack_planner = MiniStackPlanner(
+        file_list=slc_file_list,
+        dates=slc_date_list,
+        is_compressed=is_compressed,
+        output_folder=Path("fake_dir"),
+        compressed_slc_plan=plan,
+    )
+
+    # This currently works ONLY for one single ministack planning
+    # (e.g. manually separating ministack runs and re-passing in CCSLCs)
+    ms_size = 3
+    ministacks = ministack_planner.plan(ms_size)
+
+    compslcs = [m.get_compressed_slc_info() for m in ministacks]
+    if plan == "always_first":
+        assert all(c.reference_date == slc_date_list[0] for c in compslcs)
+    elif plan == "first_per_ministack":
+        assert compslcs[0].reference_date == slc_date_list[0]
+        assert compslcs[1].reference_date == slc_date_list[ms_size]
+        assert compslcs[2].reference_date == slc_date_list[ms_size * 2]
+    elif plan == "last_per_ministack":
+        assert compslcs[0].reference_date == slc_date_list[ms_size - 1]
+        assert compslcs[1].reference_date == slc_date_list[2 * ms_size - 1]
+        assert compslcs[2].reference_date == slc_date_list[3 * ms_size - 1]