Fixed end_datetime selection when splitting indices in a datetime-based indexing strategy

CHANGELOG.md

@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 ### Fixed
 
 - Fixed bulk_sync_prep_create_item to properly detect duplicates across indexes. [#575](https://github.com/stac-utils/stac-fastapi-elasticsearch-opensearch/pull/575)
+- Fixed end_datetime selection when splitting indices in a datetime-based indexing strategy. [#591](https://github.com/stac-utils/stac-fastapi-elasticsearch-opensearch/pull/591)
 
 ### Removed
 

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/search_engine/inserters.py

@@ -257,8 +257,10 @@ async def _get_target_index_internal(
                     extract_date(latest_item["_source"]["properties"]["datetime"])
                 ),
                 end_datetime=str(
-                    extract_date(latest_item["_source"]["properties"]["end_datetime"])
-                ),
+                    extract_first_date_from_index(aliases_dict["end_datetime"])
+                )
+                if aliases_dict.get("end_datetime")
+                else None,
             )
 
             await self.datetime_manager.handle_oversized_index(

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/search_engine/selection/selectors.py

@@ -1,5 +1,5 @@
 """Async index selectors with datetime-based filtering."""
-
+import logging
 from typing import Any, Dict, List, Optional, Tuple
 
 from stac_fastapi.core.utilities import get_bool_env
@@ -10,6 +10,8 @@
 from .base import BaseIndexSelector
 from .cache_manager import IndexAliasLoader, IndexCacheManager
 
+logger = logging.getLogger(__name__)
+
 
 class DatetimeBasedIndexSelector(BaseIndexSelector):
     """Asynchronous index selector that filters indices based on datetime criteria with caching."""
@@ -104,7 +106,11 @@ async def select_indexes(
                 )
                 selected_indexes.extend(filtered_indexes)
 
-            return ",".join(selected_indexes) if selected_indexes else ""
+            if selected_indexes:
+                return ",".join(selected_indexes)
+            else:
+                logger.error("No indexes found matching the datetime criteria.")
+                return ITEM_INDICES
 
         return ITEM_INDICES