From bb7f6bc143e7f6235cfbc0e1b8f87f66a58234af Mon Sep 17 00:00:00 2001 From: andrei Date: Thu, 5 May 2022 15:00:53 +0300 Subject: [PATCH] test_lib test_update_utxoset passing --- planetmint/backend/tarantool/query.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/planetmint/backend/tarantool/query.py b/planetmint/backend/tarantool/query.py index 8eba95b..ca7c85e 100644 --- a/planetmint/backend/tarantool/query.py +++ b/planetmint/backend/tarantool/query.py @@ -335,16 +335,13 @@ def delete_transactions(connection, txn_ids: list): for _id in txn_ids: assets_space.delete(_id, index="txid_search") + @register_query(TarantoolDB) def store_unspent_outputs(connection, *unspent_outputs: list): space = connection.space('utxos') if unspent_outputs: for utxo in unspent_outputs: - try: - yield space.insert((utxo['transaction_id'], utxo['output_index'])) - except DuplicateKeyError: - # TODO log warning at least - pass + space.insert((utxo['transaction_id'], utxo['output_index'])) @register_query(TarantoolDB) @@ -352,7 +349,7 @@ def delete_unspent_outputs(connection, *unspent_outputs: list): space = connection.space('utxos') if unspent_outputs: for utxo in unspent_outputs: - yield space.delete((utxo['transaction_id'], utxo['output_index'])) + space.delete((utxo['transaction_id'], utxo['output_index'])) @register_query(TarantoolDB) @@ -360,6 +357,7 @@ def get_unspent_outputs(connection): space = connection.space('utxos') return space.select() + @register_query(TarantoolDB) def store_pre_commit_state(connection, state: dict): space = connection.space("pre_commits")