skip item if duplicate id

2023-10-03 09:24:51 +08:00
parent 6ceb0ccf5b
commit 09f40a85dc
1 changed files with 4 additions and 0 deletions
--- a/packages/db/elastic_migrations/migrate_from_elastic.py
+++ b/packages/db/elastic_migrations/migrate_from_elastic.py
@ -440,6 +440,10 @@ async def main():
                original_html,
                deleted_at,
            )
+            if id in library_items_original_ids:
+                print('Skipping item', doc_id, 'because it already exists in postgres')
+                continue
+
            library_items.append(library_item)
            library_items_original_ids.append(doc_id)