fix: handle context errors as transient errors

internal/provider/kubernetes/controller.go

@@ -256,7 +256,9 @@ func isTransientError(err error) bool {
 		kerrors.IsServiceUnavailable(err) ||
 		kerrors.IsStoreReadError(err) ||
 		kerrors.IsInternalError(err) ||
-		kerrors.IsUnexpectedServerError(err)
+		kerrors.IsUnexpectedServerError(err) ||
+		errors.Is(err, context.Canceled) ||
+		errors.Is(err, context.DeadlineExceeded)
 }
 
 // Reconcile handles reconciling all resources in a single call. Any resource event should enqueue the

internal/provider/kubernetes/controller_test.go

@@ -1603,6 +1603,12 @@ func TestIsTransientError(t *testing.T) {
 	serviceUnavailableErr := kerrors.NewServiceUnavailable("service unavailable")
 	badRequestErr := kerrors.NewBadRequest("bad request")
 
+	// new test errors for context
+	canceledErr := context.Canceled
+	deadlineExceededErr := context.DeadlineExceeded
+	wrappedCanceledErr := fmt.Errorf("wrapped: %w", context.Canceled)
+	wrappedDeadlineExceededErr := fmt.Errorf("wrapped: %w", context.DeadlineExceeded)
+
 	testCases := []struct {
 		name     string
 		err      error
@@ -1614,6 +1620,10 @@ func TestIsTransientError(t *testing.T) {
 		{"ServiceUnavailable", serviceUnavailableErr, true},
 		{"BadRequest", badRequestErr, false},
 		{"NilError", nil, false},
+		{"ContextCanceled", canceledErr, true},
+		{"ContextDeadlineExceeded", deadlineExceededErr, true},
+		{"WrappedContextCanceled", wrappedCanceledErr, true},
+		{"WrappedContextDeadlineExceeded", wrappedDeadlineExceededErr, true},
 	}
 
 	for _, tc := range testCases {

internal/provider/kubernetes/filters.go

@@ -7,7 +7,7 @@
 
 import (
 	"context"
 	"fmt"
 
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
@@ -24,8 +24,8 @@
 		uExtResourceList := &unstructured.UnstructuredList{}
 		uExtResourceList.SetGroupVersionKind(gvk)
 		if err := r.client.List(ctx, uExtResourceList); err != nil {
-			r.log.Info("no associated resources found for %s", gvk.String())
-			return nil, fmt.Errorf("failed to list %s: %w", gvk.String(), err)
+			r.log.Info("no associated resources found", "GVK", gvk.String())
+			return nil, err
 		}
 
 		uExtResources := uExtResourceList.Items
@@ -57,8 +57,8 @@
 		uExtResourceList := &unstructured.UnstructuredList{}
 		uExtResourceList.SetGroupVersionKind(gvk)
 		if err := r.client.List(ctx, uExtResourceList); err != nil {
-			r.log.Info("no associated backend resources found for %s", gvk.String())
-			return nil, fmt.Errorf("failed to list %s: %w", gvk.String(), err)
+			r.log.Info("no associated backend resources found", "GVK", gvk.String())
+			return nil, err
 		}
 
 		uExtResources := uExtResourceList.Items
@@ -86,7 +86,8 @@
 func (r *gatewayAPIReconciler) getHTTPRouteFilter(ctx context.Context, name, namespace string) (*egv1a1.HTTPRouteFilter, error) {
 	hrf := new(egv1a1.HTTPRouteFilter)
 	if err := r.client.Get(ctx, types.NamespacedName{Namespace: namespace, Name: name}, hrf); err != nil {
-		return nil, fmt.Errorf("failed to get HTTPRouteFilter: %w", err)
+		r.log.Info("failed to get HTTPRouteFilter", "name", name, "namespace", namespace)
+		return nil, err
 	}
 	return hrf, nil
 }
@@ -122,7 +123,6 @@
 			resourceMap.allAssociatedConfigMaps.Insert(utils.NamespacedName(configMap).String())
 			resourceTree.ConfigMaps = append(resourceTree.ConfigMaps, configMap)
 			r.log.Info("processing ConfigMap", "namespace", filter.Namespace, "name", string(filter.Spec.DirectResponse.Body.ValueRef.Name))
-
 		}
 	}
 }

release-notes/current.yaml

@@ -12,8 +12,9 @@ new features: |
 
 bug fixes: |
   Fixed %ROUTE_KIND% operator to be lower-cased when used by clusterStatName in EnvoyProxy API.
-  Fixed maxAcceptPerSocketEvent being ignored in ClientTrafficPolicy
+  Fixed maxAcceptPerSocketEvent being ignored in ClientTrafficPolicy.
   Fixed the topologyInjectorDisabled and the local cluster was not defined.
+  Fixed handling of context-related transient errors to prevent incorrect state reconciliation and unintended behavior.
 
 # Enhancements that improve performance.
 performance improvements: |