removing logs just go to the commit before if you want lags

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

terraform/eks/daemon/gpuBurner.yaml

@@ -26,3 +26,4 @@ spec:
           resources:
             limits:
               nvidia.com/gpu: 1
+

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

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)

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