diff --git a/terraform/eks/daemon/gpu/main.tf b/terraform/eks/daemon/gpu/main.tf index b5e1eacce..658b78269 100644 --- a/terraform/eks/daemon/gpu/main.tf +++ b/terraform/eks/daemon/gpu/main.tf @@ -42,9 +42,9 @@ resource "aws_eks_node_group" "this" { subnet_ids = module.basic_components.public_subnet_ids scaling_config { - desired_size = 2 - max_size = 2 - min_size = 2 + desired_size = 1 + max_size = 1 + min_size = 1 } ami_type = var.ami_type @@ -712,7 +712,6 @@ resource "null_resource" "validator" { provisioner "local-exec" { command = <<-EOT echo "Validating EKS metrics/logs for EMF" - kubectl apply -f ../gpuBurner.yaml cd ../../../.. go test ${var.test_dir} -eksClusterName=${aws_eks_cluster.this.name} -computeType=EKS -v -eksDeploymentStrategy=DAEMON -eksGpuType=nvidia EOT diff --git a/terraform/eks/daemon/gpuBurner.yaml b/terraform/eks/daemon/gpuBurner.yaml index 1c3e164a5..4fad95303 100644 --- a/terraform/eks/daemon/gpuBurner.yaml +++ b/terraform/eks/daemon/gpuBurner.yaml @@ -26,3 +26,4 @@ spec: resources: limits: nvidia.com/gpu: 1 + diff --git a/test/metric/container_insights_util.go b/test/metric/container_insights_util.go index e8b05e7e6..ae014079d 100644 --- a/test/metric/container_insights_util.go +++ b/test/metric/container_insights_util.go @@ -193,9 +193,6 @@ func ValidateLogs(env *environment.MetaData) status.TestResult { } for _, instance := range eKSInstances { - fmt.Println("Number of eks Instances", len(eKSInstances)) - fmt.Println("This is the instance", instance.InstanceName) - fmt.Println("This is the instance", instance) stream := *instance.InstanceName err = awsservice.ValidateLogs( @@ -212,10 +209,8 @@ func ValidateLogs(env *environment.MetaData) status.TestResult { if innerErr != nil { return "", fmt.Errorf("failed to unmarshal log file: %w", innerErr) } - log.Printf("The eksClusterType is: %v", eksClusterType.Type) jsonSchema, ok := eks_resources.EksClusterValidationMap[eksClusterType.Type] if !ok { - log.Printf("Error for this eksClusterType: %v", eksClusterType.Type) return "", errors.New("invalid cluster type provided") } return jsonSchema, nil diff --git a/test/metric/metric_value_query.go b/test/metric/metric_value_query.go index 23f4464f8..eea358074 100644 --- a/test/metric/metric_value_query.go +++ b/test/metric/metric_value_query.go @@ -57,7 +57,6 @@ func (n *MetricValueFetcher) Fetch(namespace, metricName string, metricSpecificD EndTime: &endTime, MetricDataQueries: metricDataQueries, } - log.Print("This is the the getMetric data input", getMetricDataInput, getMetricDataInput.StartTime, getMetricDataInput.EndTime, getMetricDataInput.MetricDataQueries) log.Printf("Metric data input: namespace %v, name %v, stat %v, period %v", namespace, metricName, stat, metricQueryPeriod) diff --git a/util/awsservice/cloudwatchlogs.go b/util/awsservice/cloudwatchlogs.go index 7ba1f5d3e..10a9f830b 100644 --- a/util/awsservice/cloudwatchlogs.go +++ b/util/awsservice/cloudwatchlogs.go @@ -242,7 +242,6 @@ func WithSchema(schema string) SchemaRetriever { func AssertLogSchema(schemaRetriever SchemaRetriever) LogEventValidator { return func(event types.OutputLogEvent) error { message := *event.Message - fmt.Println("This is the message", message) if schemaRetriever == nil { return errors.New("nil schema retriever") } @@ -254,9 +253,6 @@ func AssertLogSchema(schemaRetriever SchemaRetriever) LogEventValidator { if err != nil { return fmt.Errorf("failed to execute schema validator: %w", err) } else if len(keyErrors) > 0 { - fmt.Println("This is the length of key errors", len(keyErrors)) - fmt.Printf("This is the first key errors info: Property Path: %s Invalid Value %s and the message %s \n ", keyErrors[0].PropertyPath, keyErrors[0].InvalidValue, keyErrors[0].Message) - return fmt.Errorf("failed schema validation: %v | schema: %s | log: %s", keyErrors, schema, message) } return nil