| | |
|---|
| | | f5 = dask.delayed(l2_data_manager.TradePointManager.delete_count_info_for_cancel_buy)(code) |
|---|
| | | f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code) |
|---|
| | | dask.compute(f1, f2, f3, f4, f5, f6) |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == "__main__": |
|---|
| | | code = "600246" |
|---|
| | | f2 = dask.delayed(l2_data_manager.TradePointManager.delete_buy_point)(code) |
|---|
| | | f3 = dask.delayed(l2_data_manager.TradePointManager.delete_buy_cancel_point)(code) |
|---|
| | | f4 = dask.delayed(l2_data_manager.TradePointManager.delete_compute_info_for_cancel_buy)(code) |
|---|
| | | f5 = dask.delayed(l2_data_manager.TradePointManager.delete_count_info_for_cancel_buy)(code) |
|---|
| | | f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code) |
|---|
| | | dask.compute(f2, f3, f4, f5, f6) |
|---|
