Mirroristas/planetmint
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint.git synced 2025-11-25 15:05:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

adjusted store_asset behaviour to match mongodb implementation

Browse Source 
Signed-off-by: Lorenz Herzberger <lorenzherzberger@gmail.com>
This commit is contained in:
Lorenz Herzberger 2022-06-21 11:22:46 +02:00
parent 772b28eabc
commit 1fb42242d7
No known key found for this signature in database
GPG Key ID: FA5EE906EB55316A
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
planetmint/backend/tarantool/query.py
View File

@ -7,10 +7,10 @@
from secrets import token_hex from secrets import token_hex
from hashlib import sha256 from hashlib import sha256
from operator import itemgetter from operator import itemgetter
import tarantool.error
import json import json
from tarantool.error import DatabaseError
from planetmint.backend import query from planetmint.backend import query
from planetmint.backend.utils import module_dispatch_registrar from planetmint.backend.utils import module_dispatch_registrar
from planetmint.backend.tarantool.connection import TarantoolDBConnection from planetmint.backend.tarantool.connection import TarantoolDBConnection
@ -138,12 +138,14 @@ def store_asset(connection, asset):
obj[0] = json.dumps(obj[0]) obj[0] = json.dumps(obj[0])
return tuple(obj) return tuple(obj)
else: else:
(json.dumps(obj), obj["id"], obj["id"]) return (json.dumps(obj), obj["id"], obj["id"])
try:
return connection.run( return connection.run(
connection.space("assets").insert(convert(asset)), connection.space("assets").insert(convert(asset)),
only_data=False only_data=False
) )
except DatabaseError:
pass
@register_query(TarantoolDBConnection) @register_query(TarantoolDBConnection)