removed-logs

Author: intojhanurag

pkg/controller/mcpserver_controller.go

@@ -131,7 +131,6 @@ func (r *MCPServerReconciler) reconcileStatus(
 
 	// Set Accepted condition based on validation
 	if err := r.validateMCPServer(server); err != nil {
-		log.FromContext(ctx).Info("MCPServer validation failed", "name", server.Name, "error", err.Error())
 		setAcceptedCondition(server, false, kagentdevv1alpha1.MCPServerReasonInvalidConfig, err.Error())
 		// If validation fails, set other conditions as unknown/false
 		setResolvedRefsCondition(
@@ -153,7 +152,6 @@ func (r *MCPServerReconciler) reconcileStatus(
 			"Configuration validation failed",
 		)
 	} else {
-		log.FromContext(ctx).Info("MCPServer validation passed", "name", server.Name)
 		setAcceptedCondition(
 			server,
 			true,
@@ -171,7 +169,6 @@ func (r *MCPServerReconciler) reconcileStatus(
 
 		// Set Programmed condition based on reconcile result
 		if reconcileErr != nil {
-			log.FromContext(ctx).Error(reconcileErr, "MCPServer reconcile failed", "name", server.Name)
 			setProgrammedCondition(
 				server,
 				false,
@@ -184,7 +181,6 @@ func (r *MCPServerReconciler) reconcileStatus(
 				"Resources failed to be created",
 			)
 		} else {
-			log.FromContext(ctx).Info("MCPServer reconcile succeeded", "name", server.Name)
 			setProgrammedCondition(server,
 				true,
 				kagentdevv1alpha1.MCPServerReasonProgrammed,
@@ -229,10 +225,8 @@ func (r *MCPServerReconciler) checkReadyCondition(ctx context.Context, server *k
 	deploymentName := server.Name
 	if err := r.Get(ctx, client.ObjectKey{Name: deploymentName, Namespace: server.Namespace}, deployment); err != nil {
 		if client.IgnoreNotFound(err) == nil {
-			log.FromContext(ctx).Info("MCPServer deployment not found", "name", server.Name)
 			setReadyCondition(server, false, kagentdevv1alpha1.MCPServerReasonPodsNotReady, "Deployment not found")
 		} else {
-			log.FromContext(ctx).Error(err, "Error getting MCPServer deployment", "name", server.Name)
 			setReadyCondition(
 				server,
 				false,
@@ -246,10 +240,6 @@ func (r *MCPServerReconciler) checkReadyCondition(ctx context.Context, server *k
 	// Check if deployment is available
 	// A deployment is considered ready when it has the desired number of available replicas
 	if deployment.Status.AvailableReplicas > 0 && deployment.Status.AvailableReplicas == deployment.Status.Replicas {
-		log.FromContext(ctx).Info("MCPServer status transitioned to Healthy",
-			"name", server.Name,
-			"availableReplicas", deployment.Status.AvailableReplicas,
-			"totalReplicas", deployment.Status.Replicas)
 		setReadyCondition(
 			server,
 			true,
@@ -259,10 +249,6 @@ func (r *MCPServerReconciler) checkReadyCondition(ctx context.Context, server *k
 	} else {
 		message := fmt.Sprintf("Deployment not ready: %d/%d replicas available",
 			deployment.Status.AvailableReplicas, deployment.Status.Replicas)
-		log.FromContext(ctx).Info("MCPServer deployment not ready",
-			"name", server.Name,
-			"availableReplicas", deployment.Status.AvailableReplicas,
-			"totalReplicas", deployment.Status.Replicas)
 		setReadyCondition(server, false, kagentdevv1alpha1.MCPServerReasonNotAvailable, message)
 	}
 }

pkg/controller/transportadapter/transportadapter_translator.go

@@ -83,7 +83,6 @@ func (t *transportAdapterTranslator) translateTransportAdapterDeployment(
 	server *v1alpha1.MCPServer,
 ) (*appsv1.Deployment, error) {
 	image := server.Spec.Deployment.Image
-	originalImage := image
 	if image == "" && server.Spec.Deployment.Cmd == "uvx" {
 		image = "ghcr.io/astral-sh/uv:debian"
 		klog.Infof("MCPServer %s: Injected default image for uvx command: %s", server.Name, image)
@@ -95,10 +94,7 @@ func (t *transportAdapterTranslator) translateTransportAdapterDeployment(
 	if image == "" {
 		return nil, fmt.Errorf("image must be specified for MCPServer %s or the command must be 'uvx' or 'npx'", server.Name)
 	}
-	if originalImage == "" {
-		klog.Infof("MCPServer %s: default image injected: %s", server.Name, image)
-	}
-
+	
 	// Create environment variables from secrets for envFrom
 	secretEnvFrom := t.createSecretEnvFrom(server.Spec.Deployment.SecretRefs)