Merge pull request #67 from opera-adt/dev

v1.0.9

Author: cmarshak

CHANGELOG.md

@@ -6,6 +6,11 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [PEP 440](https://www.python.org/dev/peps/pep-0440/)
 and uses [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.0.9] - 2026-01-07
+
+### Changed
+* Update the delta_window_days from 365 to 60 (i.e. from a year to 2 months). This enforces a baseline to account for some seasonality via its construction.
+
 ## [1.0.8] - 2025-11-10
 
 ### Changed

src/dist_s1_enumerator/dist_enum.py

@@ -17,7 +17,7 @@ def enumerate_one_dist_s1_product(
     lookback_strategy: str = 'multi_window',
     post_date_buffer_days: int = 1,
     max_pre_imgs_per_burst: int | list[int] | tuple[int, ...] = (5, 5, 5),
-    delta_window_days: int = 365,
+    delta_window_days: int = 60,
     delta_lookback_days: int | list[int] | tuple[int, ...] = 365,
     min_pre_imgs_per_burst: int = 1,
     tqdm_enabled: bool = True,
@@ -61,7 +61,7 @@ def enumerate_one_dist_s1_product(
             - Expects a single integer, tuples/lists will throw an error.
             - This means the maximum pre-images on prior to the post-date.
     delta_window_days : int, optional
-        The acceptable window of time to search for pre-image RTC-S1 data. Default is 365 days.
+        The acceptable window of time to search for pre-image RTC-S1 data. Default is 60 days (or 2 months).
         This amounts to roughly `post_date - lookback_days - delta_window_days` to `post_date - lookback_days`.
         If lookback strategy is 'multi_window', this means the maximum window of time to search for pre-images on each
         anniversary date where `post_date - n * lookback_days` are the anniversary dates for n = 1,....
@@ -235,7 +235,7 @@ def enumerate_dist_s1_products(
     min_pre_imgs_per_burst: int = 1,
     tqdm_enabled: bool = True,
     delta_lookback_days: int = 365,
-    delta_window_days: int = 365,
+    delta_window_days: int = 60,
 ) -> gpd.GeoDataFrame:
     """
     Enumerate DIST-S1 products from a stack of RTC-S1 metadata and a list of MGRS tiles.
@@ -275,7 +275,7 @@ def enumerate_dist_s1_products(
         anniversary date where `post_date - n * lookback_days` are the anniversary dates for n = 1,....
         If lookback strategy is 'immediate_lookback', this must be set to 0.
     delta_window_days : int, optional
-        The acceptable window of time to search for pre-image RTC-S1 data. Default is 365 days.
+        The acceptable window of time to search for pre-image RTC-S1 data. Default is 60 days (or 2 months).
         This amounts to roughly `post_date - lookback_days - delta_window_days` to `post_date - lookback_days`.
         If lookback strategy is 'multi_window', this means the maximum window of time to search for pre-images on each
         anniversary date where `post_date - n * lookback_days` are the anniversary dates for n = 1,....

src/dist_s1_enumerator/dist_enum_inputs.py

@@ -34,7 +34,7 @@ def enumerate_dist_s1_workflow_inputs(
     max_pre_imgs_per_burst: int | list[int] | tuple[int, ...] = (5, 5, 5),
     min_pre_imgs_per_burst: int = 1,
     delta_lookback_days: int | list[int] | tuple[int, ...] = 365,
-    delta_window_days: int = 365,
+    delta_window_days: int = 60,
     df_ts: gpd.GeoDataFrame | None = None,
 ) -> list[dict]:
     """Enumerate the inputs for a DIST-S1 workflow.

tests/test_dist_enum.py

@@ -68,7 +68,7 @@ def mock_response_from_asf_daac(
             2,
         ),  # multiple MGRS tiles over Los Angeles
         (['01UBT'], None, 'immediate_lookback', 0, 365, 10, 2),  # Aleutian Chain at the antimeridian
-        (['15RXN'], [63], 'multi_window', 365, 365, (5, 5, 5), 1),  # Waxlake delta, VV+VH
+        (['15RXN'], [63], 'multi_window', 365, 60, (5, 5, 5), 1),  # Waxlake delta, VV+VH
     ],
 )
 def test_dist_enum_default_strategies(
@@ -273,6 +273,7 @@ def test_dist_enum_one_with_multi_window_with_multiple_polarizations_and_asf_daa
         # Need to look back further for valid VV+VH data
         delta_lookback_days=(1460, 1095, 730, 365),
         max_pre_imgs_per_burst=(3, 3, 3, 4),
+        delta_window_days=365,
     )
 
     assert sorted(df_product.polarizations.unique().tolist()) == ['HH+HV', 'VV+VH']
@@ -305,6 +306,7 @@ def test_dist_enum_one_with_multi_window_with_asf_daac() -> None:
         lookback_strategy='multi_window',
         delta_lookback_days=(1095, 730, 365),
         max_pre_imgs_per_burst=(3, 3, 4),
+        delta_window_days=365,
     )
     burst_ids_expected = [
         'T144-308024-IW1',
@@ -363,4 +365,5 @@ def test_dist_enum_one_with_multi_window_with_asf_daac_single_polarization() ->
             lookback_strategy='multi_window',
             delta_lookback_days=(730, 365),
             max_pre_imgs_per_burst=(3, 4),
+            delta_window_days=365,
         )

tests/test_dist_enum_inputs.py

@@ -55,6 +55,7 @@ def test_enumerate_dist_s1_workflow_inputs_for_time_series(test_dir: Path) -> No
         stop_acq_dt='2024-04-01',
         lookback_strategy='multi_window',
         delta_lookback_days=365,
+        delta_window_days=60,
         max_pre_imgs_per_burst=5,
         df_ts=df_ts,
     )