bug修复

Administrator

2023-07-20 8031d02ace0b725ff168b55f4732f5821cf773c0

 trade/trade_result_manager.py

@@ -34,7 +34,8 @@
                                                                     total_datas[-1]["index"])
    f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
    f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
    dask.compute(f1, f2, f3, f4, f5, f6, f7)
    f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)
    dask.compute(f1, f2, f3, f4, f5, f6, f7, f8)


# 真实买成功
@@ -93,7 +94,9 @@
    f5 = dask.delayed(l2_data_manager.TradePointManager.delete_count_info_for_cancel_buy)(code)
    f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
    f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
    dask.compute(f1, f2, f3, f4, f5, f6, f7)
    f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)

    dask.compute(f1, f2, f3, f4, f5, f6, f7, f8)


if __name__ == "__main__":
@@ -104,4 +107,5 @@
    f5 = dask.delayed(l2_data_manager.TradePointManager.delete_count_info_for_cancel_buy)(code)
    f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
    f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
    dask.compute(f2, f3, f4, f5, f6, f7)
    f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)
    dask.compute(f2, f3, f4, f5, f6, f7, f8)