| | |
|---|
| | | from huaxin_client.client_network import SendResponseSkManager |
|---|
| | | from l2 import l2_data_manager_new, l2_log, code_price_manager, l2_data_util, l2_data_manager, transaction_progress |
|---|
| | | from l2.cancel_buy_strategy import HourCancelBigNumComputer, LCancelBigNumComputer, DCancelBigNumComputer, \ |
|---|
| | | GCancelBigNumComputer |
|---|
| | | GCancelBigNumComputer, SecondCancelBigNumComputer |
|---|
| | | from l2.huaxin import huaxin_target_codes_manager |
|---|
| | | from l2.huaxin.huaxin_target_codes_manager import HuaXinL1TargetCodesManager |
|---|
| | | from l2.l2_data_manager_new import L2TradeDataProcessor |
|---|
| | |
|---|
| | | buy_progress_index, |
|---|
| | | total_datas, |
|---|
| | | num_operate_map) |
|---|
| | | dask.compute(f1, f2, f3) |
|---|
| | | |
|---|
| | | f4 = dask.delayed( |
|---|
| | | SecondCancelBigNumComputer().set_transaction_index)( |
|---|
| | | code, |
|---|
| | | buy_progress_index) |
|---|
| | | |
|---|
| | | dask.compute(f1, f2, f3, f4) |
|---|
| | | except Exception as e: |
|---|
| | | hx_logger_l2_transaction.exception(e) |
|---|
| | | finally: |
|---|
