lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-26 08:45:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix order submit retry

Browse Source
This commit is contained in:
c9s 2023-03-02 15:41:11 +08:00
parent 729d32af70
commit 01ecdc8d6b
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/bbgo/order_execution.go
View File

@ -357,12 +357,16 @@ batchRetryOrder:
// iterate the error index and re-submit the order // iterate the error index and re-submit the order
log.Warnf("starting retry round #%d...", retryRound+1) log.Warnf("starting retry round #%d...", retryRound+1)
for _, idx := range errIdxNext { for _, idx := range errIdx {
submitOrder := submitOrders[idx] submitOrder := submitOrders[idx]
op := func() error { op := func() error {
// can allocate permanent error backoff.Permanent(err) to stop backoff // can allocate permanent error backoff.Permanent(err) to stop backoff
createdOrder, err2 := exchange.SubmitOrder(timeoutCtx, submitOrder) createdOrder, err2 := exchange.SubmitOrder(timeoutCtx, submitOrder)
if err2 != nil {
log.WithError(err2).Errorf("submit order error")
}
if err2 == nil && createdOrder != nil { if err2 == nil && createdOrder != nil {
// if the order is successfully created, then we should copy the order tag // if the order is successfully created, then we should copy the order tag
createdOrder.Tag = submitOrder.Tag createdOrder.Tag = submitOrder.Tag
@ -379,9 +383,10 @@ batchRetryOrder:
var bo backoff.BackOff = backoff.NewExponentialBackOff() var bo backoff.BackOff = backoff.NewExponentialBackOff()
bo = backoff.WithMaxRetries(bo, backoffMaxRetries) bo = backoff.WithMaxRetries(bo, backoffMaxRetries)
bo = backoff.WithContext(bo, timeoutCtx) // bo = backoff.WithContext(bo, timeoutCtx)
if err2 := backoff.Retry(op, bo); err2 != nil { if err2 := backoff.Retry(op, bo); err2 != nil {
if err2 == context.Canceled { if err2 == context.Canceled {
log.Warnf("context canceled error, stop retry")
break batchRetryOrder break batchRetryOrder
} }