|
|
@@ -8,7 +8,6 @@ import (
|
|
|
"fmt"
|
|
|
"io"
|
|
|
"io/ioutil"
|
|
|
- "log"
|
|
|
"net/http"
|
|
|
"os"
|
|
|
"regexp"
|
|
|
@@ -21,6 +20,7 @@ import (
|
|
|
|
|
|
"github.com/kubecost/cost-model/pkg/clustercache"
|
|
|
"github.com/kubecost/cost-model/pkg/errors"
|
|
|
+ "github.com/kubecost/cost-model/pkg/log"
|
|
|
"github.com/kubecost/cost-model/pkg/util"
|
|
|
|
|
|
"github.com/aws/aws-sdk-go/aws"
|
|
|
@@ -1343,7 +1343,7 @@ func (a *AWS) GetDisks() ([]byte, error) {
|
|
|
|
|
|
errors := []error{}
|
|
|
for err := range errorCh {
|
|
|
- log.Printf("[Warning]: unable to get disks: %s", err)
|
|
|
+ log.DedupedWarningf(5, "unable to get disks: %s", err)
|
|
|
errors = append(errors, err)
|
|
|
}
|
|
|
|
|
|
@@ -1984,7 +1984,7 @@ func parseSpotData(bucket string, prefix string, projectID string, region string
|
|
|
continue
|
|
|
}
|
|
|
|
|
|
- klog.V(1).Infof("Found spot info for: %s", spot.InstanceID)
|
|
|
+ log.DedupedInfof(5, "Found spot info for: %s", spot.InstanceID)
|
|
|
spots[spot.InstanceID] = &spot
|
|
|
}
|
|
|
gr.Close()
|