From 1d86af8087b8e9ae35dbff33b8d224fae03cea69 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期五, 21 三月 2025 14:32:51 +0800
Subject: [PATCH] bug修改
---
strategy/kpl_api.py | 13 ++++++-------
1 files changed, 6 insertions(+), 7 deletions(-)
diff --git a/strategy/kpl_api.py b/strategy/kpl_api.py
index b211b90..ce1f6b7 100644
--- a/strategy/kpl_api.py
+++ b/strategy/kpl_api.py
@@ -239,7 +239,6 @@
# 鍙湪鐩樹腑鏃堕棿鑾峰彇
now_time = tool.get_now_time_str()
if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME:
- print("====logger_stock_of_markets_plate====")
async_log_util.info(logger_stock_of_markets_plate, f"{its_stock['list']}")
logger.info(f"its_stock['list'] ===銆嬨�� {its_stock['list']}")
# logger.info(f"its_stock['list'][0] === {its_stock['list'][0]}")
@@ -291,12 +290,12 @@
# logger.info(f"market_sift_plate['list'][0] ======{market_sift_plate['list'][0]}")
# 鍒濆鍖栫簿閫夋澘鍧楀搴斾釜鑲″瓧鍏�
market_sift_plate_stock_dict = {}
- # if 'list' in market_sift_plate:
- # ds = []
- # for d in market_sift_plate['list']:
- # ds.append(request_plate_codes(d))
- # dask_result = batch_get_plate_codes(ds)
- # dask_result.compute()
+ if 'list' in market_sift_plate:
+ ds = []
+ for d in market_sift_plate['list']:
+ ds.append(request_plate_codes(d))
+ dask_result = batch_get_plate_codes(ds)
+ dask_result.compute()
# now_time = tool.get_now_time_str()
# if data_cache.L1_DATA_START_TIME < now_time < data_cache.CLOSING_TIME:
# logger.info(f"绮鹃�夋澘鍧楄偂绁ㄥ己搴︽暟鎹洿鏂� == {market_sift_plate_stock_dict}")
--
Gitblit v1.8.0