huaxin_client/l2_data_manager.py
@@ -1,6 +1,7 @@ # -*- coding: utf-8 -*- import json import logging import marshal import multiprocessing import queue import threading @@ -160,7 +161,7 @@ self.upload_l2_data_task_dict.pop(code) def __upload_l2_data(self, code, _queue, datas): _queue.put_nowait((code, datas, time.time())) _queue.put_nowait(marshal.dumps([code, datas, time.time()])) # 处理订单数据并上传 def __run_upload_order_task(self, code):
