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

Add a xtype parameter for future ES expansion

This commit is contained in:
Mark Veidemanis 2022-02-17 23:01:11 +00:00
parent 3111783f69
commit bc0a60a601
Signed by: m
GPG Key ID: 5ACFCEED46C0904F
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
handler/transactions.py
View File

@ -516,6 +516,7 @@ class Transactions(object):
def write_to_es(self, msgtype, cast): def write_to_es(self, msgtype, cast):
cast["type"] = msgtype cast["type"] = msgtype
cast["ts"] = str(datetime.now().isoformat()) cast["ts"] = str(datetime.now().isoformat())
cast["xtype"] = "tx"
self.es.index(index=settings.ES.Index, document=cast) self.es.index(index=settings.ES.Index, document=cast)
def get_remaining(self): def get_remaining(self):