Просмотр исходного кода

Merge pull request #495 from kubecost/niko/clustercosts

Return error from ClusterCosts if a query fails
Niko Kovacevic 5 лет назад
Родитель
Сommit
729084cc49
1 измененных файлов с 4 добавлено и 0 удалено
  1. 4 0
      pkg/costmodel/cluster.go

+ 4 - 0
pkg/costmodel/cluster.go

@@ -275,6 +275,10 @@ func ComputeClusterCosts(client prometheus.Client, provider cloud.Provider, wind
 	setCostsFromResults(costData, resChs[4].Await(), "storage", 0.0, customDiscount)
 	setCostsFromResults(costData, resChs[5].Await(), "localstorage", 0.0, customDiscount)
 
+	if ctx.ErrorCollector.IsError() {
+		return nil, ctx.Errors()[0]
+	}
+
 	cpuBreakdownMap := map[string]*ClusterCostsBreakdown{}
 	ramBreakdownMap := map[string]*ClusterCostsBreakdown{}
 	pvUsedCostMap := map[string]float64{}