pool repair only triggered for UniV3
This commit is contained in:
@@ -27,7 +27,8 @@ async def get_pool(address: str) -> OldPoolDict:
|
|||||||
except KeyError:
|
except KeyError:
|
||||||
result = address_metadata[address] = await load_pool(address)
|
result = address_metadata[address] = await load_pool(address)
|
||||||
else:
|
else:
|
||||||
if result['base'] == ADDRESS_0 or result['quote'] == ADDRESS_0:
|
if (result['exchange'] == Exchange.UniswapV3.value and
|
||||||
|
(result['base'] == ADDRESS_0 or result['quote'] == ADDRESS_0)):
|
||||||
log.warning(f'Repairing bad pool {address}')
|
log.warning(f'Repairing bad pool {address}')
|
||||||
result = address_metadata[address] = await load_pool(address, use_db=False)
|
result = address_metadata[address] = await load_pool(address, use_db=False)
|
||||||
return result
|
return result
|
||||||
|
|||||||
Reference in New Issue
Block a user