trade/huaxin/huaxin_trade_api_server.py
@@ -534,11 +534,11 @@ time.sleep(1) def run(pipe_server, queue_other_w_l2_r): def run(pipe_server, queue_other_w_l2_r, queue_l1_r_strategy_w): logger_system.info("create TradeApiServer") logger_system.info(f"trade_api_server 线程ID:{tool.get_thread_id()}") # 拉取交易信息 huaxin_trade_data_update.run() huaxin_trade_data_update.run(queue_l1_r_strategy_w) # t1 = threading.Thread(target=lambda: __set_target_codes(queue_other_w_l2_r), daemon=True) t1.start()
