diff --git a/pkg/exchange/kucoin/exchange.go b/pkg/exchange/kucoin/exchange.go index 18ca213cb..473e31af9 100644 --- a/pkg/exchange/kucoin/exchange.go +++ b/pkg/exchange/kucoin/exchange.go @@ -158,9 +158,8 @@ func (e *Exchange) QueryKLines(ctx context.Context, symbol string, interval type req.Interval(toLocalInterval(interval)) if options.StartTime != nil { req.StartAt(*options.StartTime) - } - - if options.EndTime != nil { + req.EndAt(options.StartTime.Add(1500 * interval.Duration())) + } else if options.EndTime != nil { req.EndAt(*options.EndTime) }