github/jumpserver
1
0
Fork 0
mirror of https://github.com/jumpserver/jumpserver.git synced 2026-03-18 19:12:07 +00:00
Code Issues Projects Releases Wiki Activity

refactor: 5s delay run

Browse Source
This commit is contained in:
Bai
2026-01-08 10:39:31 +08:00
parent 91fc08ffed
commit 3235c8652a
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
apps/assets/signal_handlers/node_assets_mapping.py
View File

@@ -11,7 +11,7 @@ from common.decorators import merge_delay_run
logger = get_logger(__name__)
@merge_delay_run(ttl=30)
@merge_delay_run(ttl=5)
def expire_node_asset_relation_cache(ignore_args=()):
from assets.tree.node_tree import relation
logger.debug('Expire Node-Asset relation cache')

5
apps/assets/tree/node_tree.py
View File

@@ -79,10 +79,11 @@ class AssetNodeRelation:
self.refresh_mapper_from_db_to_cache()
def refresh_mapper_from_db_to_cache(self):
mapper = self.load_mapper_from_db()
self.set_cache_mapper(mapper)
# 优先设置 pid，防止并发时多次加载 DB
self.set_cache_pid(self.pid)
self._current_mapper_pid = self.pid
mapper = self.load_mapper_from_db()
self.set_cache_mapper(mapper)
self._nid_aids_mapper = mapper
def set_cache_pid(self, pid):