[ELASTIC]: Add wait interval when no logs are needed to push

amadolid · Aug 8, 2023 · 83cc5ed · 83cc5ed
1 parent 6f51102
commit 83cc5ed
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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: