mirror touchup
This commit is contained in:
@@ -126,8 +126,8 @@ async def main():
|
|||||||
mirrorenv = ContractProxy(mirror_addr, 'MirrorEnv')
|
mirrorenv = ContractProxy(mirror_addr, 'MirrorEnv')
|
||||||
log.debug(f'Mirroring pools {", ".join(pools)}')
|
log.debug(f'Mirroring pools {", ".join(pools)}')
|
||||||
pool_infos = await asyncio.gather(*[get_pool_info(pool) for pool in pools])
|
pool_infos = await asyncio.gather(*[get_pool_info(pool) for pool in pools])
|
||||||
tx = await mirrorenv.transact.mirrorPools(pool_infos)
|
txs = await asyncio.gather(*[mirrorenv.transact.mirrorPool(info) for info in pool_infos])
|
||||||
await tx.wait()
|
await asyncio.gather(*[tx.wait() for tx in txs])
|
||||||
mirror_pools = []
|
mirror_pools = []
|
||||||
for pool in pools:
|
for pool in pools:
|
||||||
mirror_addr, mirror_inverted = await mirrorenv.pools(pool)
|
mirror_addr, mirror_inverted = await mirrorenv.pools(pool)
|
||||||
|
|||||||
Reference in New Issue
Block a user