diff --git a/scripts/sync.py b/scripts/sync.py
index e8aa1c70b..109e79cbb 100644
--- a/scripts/sync.py
+++ b/scripts/sync.py
@@ -42,6 +42,7 @@ WHERE claim.height % {shards_total} = {shard_num}
 async def consume(producer):
     es = AsyncElasticsearch()
     await async_bulk(es, producer, request_timeout=120)
+    await es.indices.refresh(index=INDEX)
     await es.close()