From 375d222b7b6c8cd3f7d4f6c6637f7fcc97e6f36c Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 16 八月 2023 13:46:32 +0800
Subject: [PATCH] ++++++++++++++++ 取消不必要的并行计算框架
---
l2/l2_data_manager_new.py | 9 ++++++---
1 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index bab87d3..f960290 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -588,12 +588,11 @@
dask_result = is_need_cancel(f1, f2, f3, f4, f5, f6, f7)
if is_first_code:
dask_result = is_need_cancel(f3, f4, f7)
-
+ l2_log.debug(code, "鎾ゅ崟璁＄畻寮�濮�")
cancel_data, cancel_msg = dask_result.compute()
-
+ l2_log.debug(code, "鎾ゅ崟璁＄畻缁撴潫")
_start_time = l2_data_log.l2_time(code, tool.get_now_timestamp() - _start_time,
"宸蹭笅鍗�-鎾ゅ崟 鍒ゆ柇鏄惁闇�瑕佹挙鍗�")
-
if cancel_data:
l2_log.debug(code, "瑙﹀彂鎾ゅ崟锛屾挙鍗曚綅缃細{} 锛屾挙鍗曞師鍥狅細{}", cancel_data["index"], cancel_msg)
l2_log.trade_record(code, "鎾ゅ崟", "'index':{} , 'msg':'{}'", cancel_data["index"], cancel_msg)
@@ -1134,11 +1133,15 @@
cls.__save_order_begin_data(code, buy_single_index, compute_index, compute_index,
buy_nums, buy_count, max_num_set_new,
cls.volume_rate_info[code][0])
+ l2_log.debug(code, "__save_order_begin_data")
limit_up_time_manager.LimitUpTimeManager().save_limit_up_time(code,
total_datas[compute_index][
"val"]["time"])
+ l2_log.debug(code, "save_limit_up_time")
cls.__virtual_buy(code, buy_single_index, compute_index, capture_time)
+ l2_log.debug(code, "__virtual_buy")
l2_data_manager.TradePointManager().delete_buy_cancel_point(code)
+ l2_log.debug(code, "delete_buy_cancel_point")
# 鏆傛椂涓嶉渶瑕�
# f5 = dask.delayed(L2LimitUpMoneyStatisticUtil.process_data)(code, buy_single_index,
# compute_index,
--
Gitblit v1.8.0