From bc0a60a6018e71353d268b616a095b7846aeaf64 Mon Sep 17 00:00:00 2001 From: Mark Veidemanis Date: Thu, 17 Feb 2022 23:01:11 +0000 Subject: [PATCH] Add a xtype parameter for future ES expansion --- handler/transactions.py | 1 + 1 file changed, 1 insertion(+) diff --git a/handler/transactions.py b/handler/transactions.py index 4c9ba7c..5b7ca1c 100644 --- a/handler/transactions.py +++ b/handler/transactions.py @@ -516,6 +516,7 @@ class Transactions(object): def write_to_es(self, msgtype, cast): cast["type"] = msgtype cast["ts"] = str(datetime.now().isoformat()) + cast["xtype"] = "tx" self.es.index(index=settings.ES.Index, document=cast) def get_remaining(self):