Merge pull request #485 from opensanctions/add-retries

retry on 429
opensanctions · Jul 20, 2024 · 387cc6e · 387cc6e
2 parents 24c4c04 + 228f9fd
commit 387cc6e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/yente/provider/opensearch.py b/yente/provider/opensearch.py
@@ -228,6 +228,8 @@ async def bulk_index(self, entities: AsyncIterator[Dict[str, Any]]) -> None:
                 chunk_size=1000,
                 yield_ok=False,
                 stats_only=True,
+                max_retries=3,
+                initial_backoff=2,
             )
         except BulkIndexError as exc:
             raise YenteIndexError(f"Could not index entities: {exc}") from exc