From 47f3ef30ebc8ee4cf714f6cfd33fcdc3331dd6cc Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 22 十一月 2024 13:07:50 +0800
Subject: [PATCH] bug修复
---
task/task_manager.py | 6 ++----
1 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/task/task_manager.py b/task/task_manager.py
index de8ed51..3d74925 100644
--- a/task/task_manager.py
+++ b/task/task_manager.py
@@ -24,7 +24,6 @@
val = queue_l1_w_strategy_r.get()
if val:
val = json.loads(val)
- # print("鏀跺埌鏉ヨ嚜L1鐨勬暟鎹細", val["type"])
# 澶勭悊鏁版嵁
type_ = val["type"]
timestamp = val.get("time")
@@ -52,10 +51,9 @@
times = _datas[0]
datas = _datas[1]
request_id = _datas[2]
- logger_l2_codes_subscript.info("({})璇诲彇L2浠ｇ爜澶勭悊闃熷垪锛氭暟閲�-{}", request_id, len(datas))
+ async_log_util.info(logger_l2_codes_subscript, "({})璇诲彇L2浠ｇ爜澶勭悊闃熷垪锛氭暟閲�-{}", request_id, len(datas))
# 鍙鐞�20s鍐呯殑鏁版嵁
if time.time() - times < 20:
- # 鑾峰彇娑ㄥ仠鍒楄〃涓殑鏁版嵁
# datas涓殑鏁版嵁鏍煎紡:(浠ｇ爜, 鐜颁环, 娑ㄥ箙, 閲�, 鏃堕棿)
if not datas:
# 娌℃湁鏁版嵁闇�瑕佸鐞�
@@ -78,7 +76,7 @@
# KPLLimitUpDataRecordManager.get_current_reasons()),
# daemon=True).start()
# time.sleep(0.2)
- logger_l2_codes_subscript.info("({})鍙戦�佸埌鍗庨懌L2浠ｇ爜澶勭悊闃熷垪锛氭暟閲�-{}", request_id, len(datas))
+ async_log_util.info(logger_l2_codes_subscript, "({})鍙戦�佸埌鍗庨懌L2浠ｇ爜澶勭悊闃熷垪锛氭暟閲�-{}", request_id, len(datas))
except Exception as e:
logging.exception(e)
logger_l2_codes_subscript.exception(e)
--
Gitblit v1.8.0