Merge pull request #99 from stac-utils/pv/bulk-error-ignore

Phil Varner · web-flow · commit c0f875d9a404 · 2022-05-05T11:54:23.000-04:00
for bulk operations, don't raise an exception if any of the ingested items fails
diff --git a/stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py b/stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py
@@ -497,6 +497,7 @@ async def bulk_async(
                 self.sync_client,
                 mk_actions(collection_id, processed_items),
                 refresh=refresh,
+                raise_on_error=False,
             ),
         )
 
@@ -508,6 +509,7 @@ def bulk_sync(
             self.sync_client,
             mk_actions(collection_id, processed_items),
             refresh=refresh,
+            raise_on_error=False,
         )
 
     # DANGER

Original file line number	Diff line number	Diff line change
`@@ -497,6 +497,7 @@ async def bulk_async(`
`497`	`497`	`self.sync_client,`
`498`	`498`	`mk_actions(collection_id, processed_items),`
`499`	`499`	`refresh=refresh,`
	`500`	`+ raise_on_error=False,`
`500`	`501`	`),`
`501`	`502`	`)`
`502`	`503`
`@@ -508,6 +509,7 @@ def bulk_sync(`
`508`	`509`	`self.sync_client,`
`509`	`510`	`mk_actions(collection_id, processed_items),`
`510`	`511`	`refresh=refresh,`
	`512`	`+ raise_on_error=False,`
`511`	`513`	`)`
`512`	`514`
`513`	`515`	`# DANGER`