update imports

Author: jonhealy1

stac_fastapi/core/stac_fastapi/core/core.py

@@ -866,7 +866,7 @@ def preprocess_item(
     @overrides
     def bulk_item_insert(
         self, items: Items, chunk_size: Optional[int] = None, **kwargs
-    ) -> int:
+    ) -> str:
         """Perform bulk insertion of items.
 
         Args:
@@ -875,7 +875,7 @@ def bulk_item_insert(
             **kwargs: Additional keyword arguments
 
         Returns:
-            int: Number of items successfully added
+            str: Message indicating number of items successfully added
 
         Raises:
             BulkInsertError: If any items fail insertion
@@ -896,7 +896,7 @@ def bulk_item_insert(
             refresh=kwargs.get("refresh", False),
             raise_errors=True,
         )
-        return success_count
+        return "sucessfully added {} items".format(success_count)
 
 
 _DEFAULT_QUERYABLES: Dict[str, Dict[str, Any]] = {

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -28,7 +28,6 @@
     mk_actions,
     mk_item_id,
 )
-from stac_fastapi.core.exceptions import BulkInsertError
 from stac_fastapi.core.extensions import filter
 from stac_fastapi.core.serializers import CollectionSerializer, ItemSerializer
 from stac_fastapi.core.utilities import MAX_LIMIT, bbox2polygon
@@ -956,16 +955,16 @@ def _handle_bulk_result(
         """
         success_count, error_list = result
 
-        if raise_errors and error_list:
-            error_messages = [
-                f"Item {e['index']['_id']}: {e['index']['error']['reason']}"
-                for e in error_list
-            ]
-            raise BulkInsertError(
-                f"Bulk operation failed with {len(error_list)} errors",
-                success_count=success_count,
-                errors=error_messages,
-            )
+        # if raise_errors and error_list:
+        #     error_messages = [
+        #         f"Item {e['index']['_id']}: {e['index']['error']['reason']}"
+        #         for e in error_list
+        #     ]
+        # raise BulkInsertError(
+        #     f"Bulk operation failed with {len(error_list)} errors",
+        #     success_count=success_count,
+        #     errors=error_messages,
+        # )
 
         return success_count, error_list
 

stac_fastapi/opensearch/stac_fastapi/opensearch/database_logic.py

@@ -31,7 +31,6 @@
     mk_actions,
     mk_item_id,
 )
-from stac_fastapi.core.exceptions import BulkInsertError
 from stac_fastapi.core.extensions import filter
 from stac_fastapi.core.utilities import MAX_LIMIT, bbox2polygon
 from stac_fastapi.opensearch.config import (
@@ -987,16 +986,16 @@ def _handle_bulk_result(
         """
         success_count, error_list = result
 
-        if raise_errors and error_list:
-            error_messages = [
-                f"Item {e['index']['_id']}: {e['index']['error']['reason']}"
-                for e in error_list
-            ]
-            raise BulkInsertError(
-                f"Bulk operation completed with {len(error_list)} errors",
-                success_count=success_count,
-                errors=error_messages,
-            )
+        # if raise_errors and error_list:
+        #     error_messages = [
+        #         f"Item {e['index']['_id']}: {e['index']['error']['reason']}"
+        #         for e in error_list
+        #     ]
+        # raise BulkInsertError(
+        #     f"Bulk operation completed with {len(error_list)} errors",
+        #     success_count=success_count,
+        #     errors=error_messages,
+        # )
 
         return success_count, error_list