From 281809779f806859c83fbc05a3ab477594ff5266 Mon Sep 17 00:00:00 2001 From: "Alexie (Boyong) Madolid" Date: Tue, 21 Nov 2023 10:36:16 +0800 Subject: [PATCH 1/2] [WEBSOCKET]: Improvements --- jaseci_serv/jaseci_serv/socket/consumer.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/jaseci_serv/jaseci_serv/socket/consumer.py b/jaseci_serv/jaseci_serv/socket/consumer.py index 31591b739d..fc32b030ff 100644 --- a/jaseci_serv/jaseci_serv/socket/consumer.py +++ b/jaseci_serv/jaseci_serv/socket/consumer.py @@ -47,6 +47,9 @@ def receive(self, text_data=None, bytes_data=None): self.group, {"type": "notify", "data": data} ) + def disconnect(self, close_code): + async_to_sync(self.channel_layer.group_discard)(self.group, self.channel_name) + def notify(self, data): self.send(text_data=dumps(data)) From cd670706ba1b5efcf6d147ceb0877f51a13b6e36 Mon Sep 17 00:00:00 2001 From: "Alexie (Boyong) Madolid" Date: Fri, 24 Nov 2023 11:26:38 +0800 Subject: [PATCH 2/2] [ELASTIC]: Remove handler on child processes --- jaseci_core/jaseci/extens/svc/elastic_svc.py | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 deletions(-) diff --git a/jaseci_core/jaseci/extens/svc/elastic_svc.py b/jaseci_core/jaseci/extens/svc/elastic_svc.py index 50c3e82871..d625d04e55 100644 --- a/jaseci_core/jaseci/extens/svc/elastic_svc.py +++ b/jaseci_core/jaseci/extens/svc/elastic_svc.py @@ -78,15 +78,16 @@ def run(self): self.app.health("timeout=1s") def post_run(self): - under_test = self.config.get("under_test", False) - if not under_test: - self.configure_elastic() - LOG_QUEUES["core"] = self.add_elastic_log_handler( - logger, self.config.get("core_log_index") or "core", under_test - ) - LOG_QUEUES["app"] = self.add_elastic_log_handler( - app_logger, self.config.get("app_log_index") or "app", under_test - ) + if multiprocessing.current_process().name == "MainProcess": + under_test = self.config.get("under_test", False) + if not under_test: + self.configure_elastic() + LOG_QUEUES["core"] = self.add_elastic_log_handler( + logger, self.config.get("core_log_index") or "core", under_test + ) + LOG_QUEUES["app"] = self.add_elastic_log_handler( + app_logger, self.config.get("app_log_index") or "app", under_test + ) def configure_elastic(self): """