diff --git a/packages/db/elastic_migrations/migrate_from_elastic.py b/packages/db/elastic_migrations/migrate_from_elastic.py
index 2c1e61b8d..2c29e0ee2 100755
--- a/packages/db/elastic_migrations/migrate_from_elastic.py
+++ b/packages/db/elastic_migrations/migrate_from_elastic.py
@@ -232,7 +232,7 @@ async def insert_into_postgres(insert_query, db_conn, records, original_ids):
     except Exception as err:
         print('Batch insert into postgres ERROR:', err)
         # excute insert query one by one if batch insert failed
-        for i, record in records:
+        for i, record in enumerate(records):
             # print original id for debugging
             print('Inserting record', original_ids[i])
             try: