XF/pluto
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Add Trade and Transaction models

Browse Source
This commit is contained in:
Mark Veidemanis
2023-03-12 12:18:45 +00:00
parent cdebded0f6
commit aa0b522d76
2 changed files with 54 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
core/clients/aggregator.py
View File

@@ -59,9 +59,9 @@ class AggregatorClient(ABC):
# for transaction_id in transaction_ids:
if not transaction_ids:
return
db.r.sadd(new_key_name, *transaction_ids)
await db.r.sadd(new_key_name, *transaction_ids)
difference = list(db.r.sdiff(new_key_name, old_key_name))
difference = list(await db.r.sdiff(new_key_name, old_key_name))
difference = db.convert(difference)
@@ -70,7 +70,7 @@ class AggregatorClient(ABC):
]
# Rename the new key to the old key so we can run the diff again
db.r.rename(new_key_name, old_key_name)
await db.r.rename(new_key_name, old_key_name)
for transaction in new_transactions:
transaction["subclass"] = self.name
# self.tx.transaction(transaction)