diff --git a/planetmint/backend/tarantool/query.py b/planetmint/backend/tarantool/query.py index b91d555..8dc9db3 100644 --- a/planetmint/backend/tarantool/query.py +++ b/planetmint/backend/tarantool/query.py @@ -116,7 +116,7 @@ def get_transactions(transactions_ids: list, connection): def store_metadatas(metadata: list, connection): space = connection.space("meta_data") for meta in metadata: - space.insert((meta["id"], meta)) + space.insert((meta["id"], meta["data"])) # @register_query(LocalMongoDBConnection) diff --git a/tests/backend/tarantool/test_queries.py b/tests/backend/tarantool/test_queries.py index 7009eb1..e943afd 100644 --- a/tests/backend/tarantool/test_queries.py +++ b/tests/backend/tarantool/test_queries.py @@ -180,12 +180,14 @@ def test_write_metadata(): query.store_metadatas(connection=conn, metadata=metadata) # check that 3 assets were written to the database + space = conn.space("meta_data") metadatas = [] for meta in metadata: - _data = conn.select(meta["id"]) + _data = space.select(meta["id"]) + _data = _data.data[0] metadatas.append({"id": _data[0], "data": _data[1]}) - metadatas = sorted(metadatas) + metadatas = sorted(metadatas, key=lambda k: k["id"]) assert len(metadatas) == 3 assert list(metadatas) == metadata