From 9251c873237d3aa149ee0e30a05ca84075553817 Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Thu, 11 Feb 2021 22:00:15 -0300 Subject: [PATCH] refresh after sync --- scripts/sync.py | 1 + 1 file changed, 1 insertion(+) 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()