From 228446979f9b2aab0f2104f0ee4d53459dc7331c Mon Sep 17 00:00:00 2001 From: Bai Date: Wed, 18 Aug 2021 15:34:15 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=94=B9=E8=BF=87=E6=9C=9F?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E8=B5=84=E4=BA=A7=E6=98=A0=E5=B0=84=E7=BC=93?= =?UTF-8?q?=E5=AD=98=E6=B8=85=E9=99=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/assets/signals_handler/node_assets_mapping.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/apps/assets/signals_handler/node_assets_mapping.py b/apps/assets/signals_handler/node_assets_mapping.py index efa3cb29f..8d9580a27 100644 --- a/apps/assets/signals_handler/node_assets_mapping.py +++ b/apps/assets/signals_handler/node_assets_mapping.py @@ -48,7 +48,6 @@ def expire_node_assets_mapping_for_memory(org_id): Node.expire_node_all_asset_ids_mapping_from_cache(root_org_id) node_assets_mapping_for_memory_pub_sub.publish(org_id) - node_assets_mapping_for_memory_pub_sub.publish(root_org_id) @receiver(post_save, sender=Node) @@ -86,7 +85,9 @@ def subscribe_node_assets_mapping_expire(sender, **kwargs): if message["type"] != "message": continue org_id = message['data'].decode() + root_org_id = Organization.ROOT_ID Node.expire_node_all_asset_ids_mapping_from_memory(org_id) + Node.expire_node_all_asset_ids_mapping_from_memory(root_org_id) logger.debug( "Expire node assets id mapping from memory of org={}, pid={}" "".format(str(org_id), os.getpid())