From f994f5d7764ee4daa758ab06aefaa3ea0684b0ff Mon Sep 17 00:00:00 2001 From: xinwen Date: Tue, 8 Feb 2022 10:44:42 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20redis=20=E8=AE=A2=E9=98=85=20bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/assets/signals_handler/node_assets_mapping.py | 2 +- apps/common/utils/connection.py | 1 + apps/orgs/signals_handler/common.py | 2 +- apps/settings/signals_handler.py | 4 +--- 4 files changed, 4 insertions(+), 5 deletions(-) diff --git a/apps/assets/signals_handler/node_assets_mapping.py b/apps/assets/signals_handler/node_assets_mapping.py index da7e8fab5..71d7c7eb3 100644 --- a/apps/assets/signals_handler/node_assets_mapping.py +++ b/apps/assets/signals_handler/node_assets_mapping.py @@ -79,7 +79,7 @@ def subscribe_node_assets_mapping_expire(sender, **kwargs): Node.expire_node_all_asset_ids_mapping_from_memory(root_org_id) def keep_subscribe_node_assets_relation(): - node_assets_mapping_for_memory_pub_sub.keep_handle_msg(handle_node_relation_change) + node_assets_mapping_for_memory_pub_sub.subscribe(handle_node_relation_change) t = threading.Thread(target=keep_subscribe_node_assets_relation) t.daemon = True diff --git a/apps/common/utils/connection.py b/apps/common/utils/connection.py index bf1462d78..a19b04f85 100644 --- a/apps/common/utils/connection.py +++ b/apps/common/utils/connection.py @@ -90,6 +90,7 @@ class RedisPubSub: def subscribe(self, _next, error=None, complete=None): ps = self.redis.pubsub() + ps.subscribe(self.ch) sub = Subscription(self.ch, ps) sub.keep_handle_msg(_next, error, complete) return sub diff --git a/apps/orgs/signals_handler/common.py b/apps/orgs/signals_handler/common.py index ff22172b6..f49b32f19 100644 --- a/apps/orgs/signals_handler/common.py +++ b/apps/orgs/signals_handler/common.py @@ -46,7 +46,7 @@ def subscribe_orgs_mapping_expire(sender, **kwargs): logger.debug("Start subscribe for expire orgs mapping from memory") def keep_subscribe_org_mapping(): - orgs_mapping_for_memory_pub_sub.keep_handle_msg( + orgs_mapping_for_memory_pub_sub.subscribe( lambda org_id: Organization.expire_orgs_mapping() ) diff --git a/apps/settings/signals_handler.py b/apps/settings/signals_handler.py index 241574995..f4163592c 100644 --- a/apps/settings/signals_handler.py +++ b/apps/settings/signals_handler.py @@ -80,9 +80,7 @@ def subscribe_settings_change(sender, **kwargs): logger.debug("Start subscribe setting change") def keep_subscribe_settings_change(): - setting_pub_sub.keep_handle_msg( - lambda name: Setting.refresh_item(name) - ) + setting_pub_sub.subscribe(lambda name: Setting.refresh_item(name)) t = threading.Thread(target=keep_subscribe_settings_change) t.daemon = True