huaxin_client/l2_data_manager.py
@@ -143,9 +143,9 @@ t1.start() t2 = threading.Thread(target=lambda: self.__run_upload_transaction_task(code), daemon=True) t2.start() t3 = threading.Thread(target=lambda: self.__run_log_task(code), daemon=True) t3.start() self.upload_l2_data_task_dict[code] = (t1, t2, t3) # t3 = threading.Thread(target=lambda: self.__run_log_task(code), daemon=True) # t3.start() self.upload_l2_data_task_dict[code] = (t1, t2) # 释放已经分配的队列 def release_distributed_upload_queue(self, code):
