forked from LBRYCommunity/lbry-sdk
refresh after sync
This commit is contained in:
parent
e12fab90d1
commit
9251c87323
1 changed files with 1 additions and 0 deletions
|
@ -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()
|
||||
|
||||
|
||||
|
|
Loading…
Reference in a new issue