diff --git a/planetmint/backend/tarantool/query.py b/planetmint/backend/tarantool/query.py
index bc4ea6e..83f4c1d 100644
--- a/planetmint/backend/tarantool/query.py
+++ b/planetmint/backend/tarantool/query.py
@@ -60,13 +60,11 @@ def store_transactions(connection, signed_transactions: list):
             )
         except:  # This is used for omitting duplicate error in database for test -> test_bigchain_api::test_double_inclusion
             continue
-
         for _in in txtuples["inputs"]:
             connection.run(
                 connection.space("inputs").insert(_in),
                 only_data=False
             )
-
         for _out in txtuples["outputs"]:
             connection.run(
                 connection.space("outputs").insert(_out),
diff --git a/planetmint/backend/tarantool/transaction/tools.py b/planetmint/backend/tarantool/transaction/tools.py
index 5660eef..28fea32 100644
--- a/planetmint/backend/tarantool/transaction/tools.py
+++ b/planetmint/backend/tarantool/transaction/tools.py
@@ -69,6 +69,7 @@ class TransactionDecompose:
         _inputs = []
         input_index = 0
         for _input in self._transaction["inputs"]:
+
             _inputs.append((self._transaction["id"],
                             _input["fulfillment"],
                             _input["owners_before"],
@@ -84,7 +85,6 @@ class TransactionDecompose:
         _keys = []
         output_index = 0
         for _output in self._transaction["outputs"]:
-            # print(f"\noutput: {_output}")
             output_id = self.__create_hash(7)
             if _output["condition"]["details"].get("subconditions") is None:
                 tmp_output = (self._transaction["id"],
diff --git a/tests/utils.py b/tests/utils.py
index ac039af..08b16b8 100644
--- a/tests/utils.py
+++ b/tests/utils.py
@@ -41,6 +41,10 @@ def flush_tarantool_db(connection, dbname):
                 connection.run(connection.space(s).delete(_id[1]), only_data=False)
             elif s in ["blocks", "abci_chains"]:
                 connection.run(connection.space(s).delete(_id[2], only_data=False))
+            elif s == "inputs":
+                connection.run(connection.space(s).delete(_id[-2], only_data=False))
+            elif s == "outputs":
+                connection.run(connection.space(s).delete(_id[-4], only_data=False))
             else:
                 connection.run(connection.space(s).delete(_id[0], only_data=False))