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

batch: fix JumpIfEmpty algorithm

Browse Source
This commit is contained in:
c9s 2023-02-09 17:11:26 +08:00
parent 5bbe4ecd57
commit 2fed98ea55
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/exchange/batch/time_range_query.go
View File

@ -72,7 +72,13 @@ func (q *AsyncTimeRangedBatchQuery) Query(ctx context.Context, ch interface{}, s
if listLen == 0 {
if q.JumpIfEmpty > 0 {
startTime = startTime.Add(q.JumpIfEmpty)
startTime2 := startTime.Add(q.JumpIfEmpty)
if startTime2.After(endTime) {
startTime = endTime
endTime = startTime2
} else {
startTime = startTime.Add(q.JumpIfEmpty)
}
log.Debugf("batch querying %T: empty records jump to %s", q.Type, startTime)
continue