We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a4ee7f9 commit 3fd3a52Copy full SHA for 3fd3a52
jaseci_core/jaseci/extens/svc/elastic_svc.py
@@ -249,10 +249,10 @@ def elastic_log_worker(elastic_index):
249
import threading
250
251
logger.info("-----------creating worker process")
252
- # worker_proc = multiprocessing.Process(
253
- # target=elastic_log_worker, args=(index,)
254
- # )
255
- worker_proc = threading.Thread(target=elastic_log_worker, args=(index,))
+ worker_proc = multiprocessing.Process(
+ target=elastic_log_worker, args=(index,)
+ )
+ # worker_proc = threading.Thread(target=elastic_log_worker, args=(index,))
256
logger.info("-----------start worker process")
257
worker_proc.start()
258
logger.info("-----------started worker process")
0 commit comments