add logging

Author: Yuri Zmytrakov

stac_fastapi/core/stac_fastapi/core/version.py

@@ -1,2 +1,3 @@
 """library version."""
+
 __version__ = "6.10.1"

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -1,4 +1,5 @@
 """Database logic."""
+
 import asyncio
 import logging
 import os

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/version.py

@@ -1,2 +1,3 @@
 """library version."""
+
 __version__ = "6.10.1"

stac_fastapi/opensearch/stac_fastapi/opensearch/database_logic.py

@@ -1,4 +1,5 @@
 """Database logic."""
+
 import asyncio
 import logging
 import os
@@ -877,10 +878,22 @@ async def execute_search(
                 self.apply_datetime_filter,
                 search,
             )
+            logger.debug(
+                f"Resolve indexes from CQL2 metadata: {index_param} for collections {collection_ids} and cql2 metadata {cql2_metadata}"
+            )
+            print(
+                f"Resolve indexes from CQL2 metadata: {index_param} for collections {collection_ids} and cql2 metadata {cql2_metadata}"
+            )
         else:
             index_param = await self.async_index_selector.select_indexes(
                 collection_ids, datetime_search
             )
+            logger.debug(
+                f"Selecte indexes: {index_param} for collections {collection_ids} and datetime search {datetime_search}"
+            )
+            print(
+                f"Selecte indexes: {index_param} for collections {collection_ids} and datetime search {datetime_search}"
+            )
         if len(index_param) > ES_MAX_URL_LENGTH - 300:
             index_param = ITEM_INDICES
             query = add_collections_to_body(collection_ids, query)

stac_fastapi/opensearch/stac_fastapi/opensearch/version.py

@@ -1,2 +1,3 @@
 """library version."""
+
 __version__ = "6.10.1"

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/aggregation/client.py

@@ -1,6 +1,5 @@
 """Client implementation for the STAC API Aggregation Extension."""
 
-
 from typing import Annotated, Any, Dict, List, Optional, Union
 from urllib.parse import unquote_plus, urljoin
 

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

@@ -256,11 +256,11 @@ async def _get_target_index_internal(
                 datetime=str(
                     extract_date(latest_item["_source"]["properties"]["datetime"])
                 ),
-                end_datetime=str(
-                    extract_first_date_from_index(aliases_dict["end_datetime"])
-                )
-                if aliases_dict.get("end_datetime")
-                else None,
+                end_datetime=(
+                    str(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/managers.py

@@ -211,15 +211,21 @@ async def handle_new_collection(
             str: Created datetime index name.
         """
         index_params = {
-            "start_datetime": str(extract_date(product_datetimes.start_datetime))
-            if primary_datetime_name == "start_datetime"
-            else None,
-            "datetime": str(extract_date(product_datetimes.datetime))
-            if primary_datetime_name == "datetime"
-            else None,
-            "end_datetime": str(extract_date(product_datetimes.end_datetime))
-            if primary_datetime_name == "start_datetime"
-            else None,
+            "start_datetime": (
+                str(extract_date(product_datetimes.start_datetime))
+                if primary_datetime_name == "start_datetime"
+                else None
+            ),
+            "datetime": (
+                str(extract_date(product_datetimes.datetime))
+                if primary_datetime_name == "datetime"
+                else None
+            ),
+            "end_datetime": (
+                str(extract_date(product_datetimes.end_datetime))
+                if primary_datetime_name == "start_datetime"
+                else None
+            ),
         }
 
         target_index = await self.index_operations.create_datetime_index(

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

@@ -1,4 +1,5 @@
 """Async index selectors with datetime-based filtering."""
+
 from typing import Any, Dict, List, Optional, Tuple
 
 from stac_fastapi.core.utilities import get_bool_env

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/version.py

@@ -1,2 +1,3 @@
 """library version."""
+
 __version__ = "6.10.1"