From 83cc5edd118451c0bf027d466bdb4ce6e0c5eb37 Mon Sep 17 00:00:00 2001 From: "Alexie (Boyong) Madolid" Date: Tue, 8 Aug 2023 22:49:15 +0800 Subject: [PATCH] [ELASTIC]: Add wait interval when no logs are needed to push --- jaseci_core/jaseci/extens/svc/elastic_svc.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/jaseci_core/jaseci/extens/svc/elastic_svc.py b/jaseci_core/jaseci/extens/svc/elastic_svc.py index ff401b9fc6..3f8966c976 100644 --- a/jaseci_core/jaseci/extens/svc/elastic_svc.py +++ b/jaseci_core/jaseci/extens/svc/elastic_svc.py @@ -7,6 +7,7 @@ from datetime import datetime from copy import copy from base64 import b64encode +from time import sleep import multiprocessing import logging.handlers @@ -132,7 +133,8 @@ def elastic_log_worker(elastic_index): try: record = log_queue.get() if record is None: - break + sleep(1) + continue elastic_record = format_elastic_record(record) self.app.doc(log=elastic_record, index=elastic_index) except Exception: