diff --git a/pybtc/connector.py b/pybtc/connector.py index d28526b..f6a0d21 100644 --- a/pybtc/connector.py +++ b/pybtc/connector.py @@ -771,6 +771,9 @@ class UTXO(): c -= 1 continue break + # if not lb: + # await asyncio.sleep(0) + # return r = set() db = set() @@ -785,9 +788,8 @@ class UTXO(): await conn.execute("DELETE FROM connector_utxo WHERE " "outpoint = ANY($1);", r) await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs) - if lb: - await conn.execute("UPDATE connector_utxo_state SET value = $1 " - "WHERE name = 'last_block';", lb) + await conn.execute("UPDATE connector_utxo_state SET value = $1 " + "WHERE name = 'last_block';", lb) await conn.execute("UPDATE connector_utxo_state SET value = $1 " "WHERE name = 'last_cached_block';", block_height) self.saved_utxo += len(rs)