connector

This commit is contained in:
4tochka 2019-05-13 18:10:00 +04:00
parent 610e01835b
commit 1d65bfe88a

View File

@ -182,14 +182,12 @@ class UTXO():
continue
break
try:
self.log.critical("load utxo " + str(len(self.missed)))
self.load_utxo_future = asyncio.Future()
l = set(self.missed)
async with self._db_pool.acquire() as conn:
rows = await conn.fetch("SELECT outpoint, connector_utxo.data "
"FROM connector_utxo "
"WHERE outpoint = ANY($1);", l)
self.log.critical("loaded "+str(len(rows)))
for i in l:
try:
self.missed.remove(i)