add bulk insert error

Author: jonhealy1

stac_fastapi/core/exceptions.py renamed to stac_fastapi/core/stac_fastapi/core/exceptions.py

@@ -28,6 +28,7 @@
     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
@@ -955,16 +956,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/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -31,6 +31,7 @@
     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 (
@@ -986,16 +987,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