This commit is contained in:
@@ -6,6 +6,7 @@ import (
|
||||
"flag"
|
||||
"fmt"
|
||||
"io"
|
||||
"maps"
|
||||
"math"
|
||||
"os"
|
||||
"os/signal"
|
||||
@@ -100,6 +101,14 @@ func Main() {
|
||||
panic(err)
|
||||
}
|
||||
bpis = b
|
||||
if period := config.Query.Period; !period.Empty() {
|
||||
before := period.Stop.Format("2006-01-02")
|
||||
for _, timeToValue := range bpis {
|
||||
maps.DeleteFunc(timeToValue, func(k string, _ float64) bool {
|
||||
return k > before
|
||||
})
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
cpiNormalizer := ana.NewNormalizer()
|
||||
|
||||
Reference in New Issue
Block a user