添加测试日志

Administrator

2024-06-17 c001539dc2c831546e429da36f0236296646c79e

 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):
        # 已经分配的回调ID
        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"已经分配的callbackid：{distibuted_callbacks_ids}")
            raise Exception("无可用的回调对象")
        self.distibuted_code_callback_dict[code] = callback_info
        return callback_info