From 51aef7e3e561494a45f13d6ff650663f161e01a0 Mon Sep 17 00:00:00 2001 From: Mahan Zendedel DH Date: Thu, 4 Jul 2024 16:02:50 +0400 Subject: [PATCH] fix: auth (#36) --- plugin/processor/compute_instance/compute_instance.go | 2 +- .../compute_instance/job_optimize_compute_instance.go | 9 ++++----- 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/plugin/processor/compute_instance/compute_instance.go b/plugin/processor/compute_instance/compute_instance.go index 39bc684..992d067 100644 --- a/plugin/processor/compute_instance/compute_instance.go +++ b/plugin/processor/compute_instance/compute_instance.go @@ -164,7 +164,7 @@ func (m *ComputeInstanceProcessor) ResultsSummary() *golang.ResultSummary { func (m *ComputeInstanceProcessor) UpdateSummary(itemId string) { i, ok := m.items.Get(itemId) - if ok && i.Wastage.Rightsizing.Recommended != nil { + if ok && i.Wastage != nil && i.Wastage.Rightsizing.Recommended != nil { totalSaving := 0.0 totalCurrentCost := 0.0 for _, v := range i.Wastage.VolumesRightsizing { diff --git a/plugin/processor/compute_instance/job_optimize_compute_instance.go b/plugin/processor/compute_instance/job_optimize_compute_instance.go index 00fc3e9..5175b3c 100644 --- a/plugin/processor/compute_instance/job_optimize_compute_instance.go +++ b/plugin/processor/compute_instance/job_optimize_compute_instance.go @@ -80,10 +80,6 @@ func (job *OptimizeComputeInstancesJob) Run(ctx context.Context) error { } } - grpcCtx := metadata.NewOutgoingContext(ctx, metadata.Pairs("workspace-name", "kaytu")) - grpcCtx, cancel := context.WithTimeout(grpcCtx, shared.GrpcOptimizeRequestTimeout) - defer cancel() - metrics := make(map[string]*golang2.Metric) for k, v := range item.Metrics { metrics[k] = &golang2.Metric{ @@ -104,7 +100,10 @@ func (job *OptimizeComputeInstancesJob) Run(ctx context.Context) error { } } - response, err := job.processor.client.GCPComputeOptimization(ctx, &golang2.GCPComputeOptimizationRequest{ + grpcCtx := metadata.NewOutgoingContext(ctx, metadata.Pairs("workspace-name", "kaytu")) + grpcCtx, cancel := context.WithTimeout(grpcCtx, shared.GrpcOptimizeRequestTimeout) + defer cancel() + response, err := job.processor.client.GCPComputeOptimization(grpcCtx, &golang2.GCPComputeOptimizationRequest{ RequestId: wrapperspb.String(requestId), CliVersion: wrapperspb.String(version.VERSION), Identification: job.processor.provider.Identify(),