trade/trade_strategy.py
@@ -486,6 +486,8 @@ threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True).start() threading.Thread(target=lambda: async_log_util.l2_data_log.run_sync(), daemon=True).start() huaxin_trade_data_update.run(queue_l1_trade_r_strategy_w, queue_strategy_w_l2_r) huaxin_trade_api.run_pipe_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r)
