From 4bb98ab3b49687265fb60754d07610d50b3b8431 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 28 六月 2024 10:55:44 +0800
Subject: [PATCH] 水下捞相关数据删除/优化目标代码处理
---
huaxin_client/code_queue_distribute_manager.py | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
diff --git a/huaxin_client/code_queue_distribute_manager.py b/huaxin_client/code_queue_distribute_manager.py
index 4105bd5..782cdbf 100644
--- a/huaxin_client/code_queue_distribute_manager.py
+++ b/huaxin_client/code_queue_distribute_manager.py
@@ -76,11 +76,14 @@
callback_info = self.get_available_callback()
if not callback_info:
distibuted_callbacks_ids = set()
+ need_release_codes = set()
for code in self.distibuted_code_callback_dict:
distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0])
# 濡傛灉浠ｇ爜娌″湪鐩爣浠ｇ爜涓氨绉婚櫎
if target_codes and code not in target_codes:
- self.release_distribute_callback(code)
+ need_release_codes.add(code)
+ for c in need_release_codes:
+ self.release_distribute_callback(c)
logger_local_huaxin_l2_error.info(f"宸茬粡鍒嗛厤鐨勪唬鐮侊細{self.distibuted_code_callback_dict.keys()}")
logger_local_huaxin_l2_error.info(f"宸茬粡鍒嗛厤鐨刢allbackid锛歿distibuted_callbacks_ids}")
# 鍒犻櫎宸茬粡娌″湪鐩爣浠ｇ爜涓殑鍒嗛厤
--
Gitblit v1.8.0