From c001539dc2c831546e429da36f0236296646c79e Mon Sep 17 00:00:00 2001 From: Administrator <admin@example.com> Date: 星期一, 17 六月 2024 13:59:33 +0800 Subject: [PATCH] 添加测试日志 --- huaxin_client/code_queue_distribute_manager.py | 8 ++++++++ 1 files changed, 8 insertions(+), 0 deletions(-) diff --git a/huaxin_client/code_queue_distribute_manager.py b/huaxin_client/code_queue_distribute_manager.py index b91cbc6..fd33373 100644 --- a/huaxin_client/code_queue_distribute_manager.py +++ b/huaxin_client/code_queue_distribute_manager.py @@ -3,6 +3,8 @@ """ import copy +from log_module.log import logger_local_huaxin_l2_error + class CodeQueueDistributeManager: # queue_list @@ -58,6 +60,7 @@ # 鑾峰彇鍙敤鐨勯槦鍒� def get_available_callback(self): + # 宸茬粡鍒嗛厤鐨勫洖璋僆D distibuted_callbacks_ids = set() for code in self.distibuted_code_callback_dict: distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0]) @@ -72,6 +75,11 @@ return self.distibuted_code_callback_dict.get(code) callback_info = self.get_available_callback() if not callback_info: + distibuted_callbacks_ids = set() + for code in self.distibuted_code_callback_dict: + distibuted_callbacks_ids.add(self.distibuted_code_callback_dict[code][0]) + logger_local_huaxin_l2_error.info(f"宸茬粡鍒嗛厤鐨勪唬鐮侊細{self.distibuted_code_callback_dict.keys()}") + logger_local_huaxin_l2_error.info(f"宸茬粡鍒嗛厤鐨刢allbackid锛歿distibuted_callbacks_ids}") raise Exception("鏃犲彲鐢ㄧ殑鍥炶皟瀵硅薄") self.distibuted_code_callback_dict[code] = callback_info return callback_info -- Gitblit v1.8.0