allow multiple hrefs, take first

xcube-dev · Dec 6, 2024 · e1fb45a · e1fb45a
1 parent 825e787
commit e1fb45a
Showing 1 changed file with 19 additions and 6 deletions.
diff --git a/xcube_stac/helper.py b/xcube_stac/helper.py
@@ -20,6 +20,7 @@
 from .constants import SCHEMA_PROCESSING_LEVEL
 from .constants import SCHEMA_COLLECTIONS
 from .constants import SCHEMA_SPATIAL_RES
+from .constants import LOG
 from .sen2.constants import CDSE_SENITNEL_2_BANDS
 from .sen2.constants import CDSE_SENTINEL_2_LEVEL_BAND_RESOLUTIONS
 from .sen2.constants import CDSE_SENTINEL_2_MIN_RESOLUTIONS
@@ -233,10 +234,16 @@ def parse_item(self, item: pystac.Item, **open_params) -> pystac.Item:
                 hrefs = self._fs.glob(
                     f"{href_base}/**/*_{asset_name}_{res_select}m.jp2"
                 )
-                if len(hrefs) != 1:
+                if len(hrefs) == 0:
                     raise DataStoreError(
-                        "No unique jp2 file found; these hrefs were found {hrefs} "
-                        "for {href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                        "No jp2 file found for "
+                        f"{href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                    )
+                elif len(hrefs) > 1:
+                    LOG.warning(
+                        f"N unique jp2 file found: {hrefs} are found "
+                        f"for {href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                        f"Href {hrefs[0]} is taken."
                     )
                 href_mod = hrefs[0]
                 time_end = hrefs[0].split("/IMG_DATA/")[0][-15:]
@@ -373,10 +380,16 @@ def parse_item(self, item: pystac.Item, **open_params) -> pystac.Item:
                 hrefs = self._fs.glob(
                     f"{href_base}/**/*_{asset_name}_{res_select}m.jp2"
                 )
-                if len(hrefs) != 1:
+                if len(hrefs) == 0:
                     raise DataStoreError(
-                        "No unique jp2 file found; these hrefs were found {hrefs} "
-                        "for {href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                        "No jp2 file found for "
+                        f"{href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                    )
+                elif len(hrefs) > 1:
+                    LOG.warning(
+                        f"N unique jp2 file found: {hrefs} are found "
+                        f"for {href_base}/**/*_{asset_name}_{res_select}m.jp2"
+                        f"Href {hrefs[0]} is taken."
                     )
                 href_mod = hrefs[0]
                 time_end = hrefs[0].split("/IMG_DATA/")[0][-15:]