Skip to content

Commit 44a4623

Browse files
authored
fix: infinite loop after delete (#22)
1 parent 4ac900c commit 44a4623

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

internal/controller/pipeline_controller.go

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@ import (
99
"github.com/pkg/errors"
1010
appsv1 "k8s.io/api/apps/v1"
1111
corev1 "k8s.io/api/core/v1"
12+
apierrors "k8s.io/apimachinery/pkg/api/errors"
1213
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1314
"k8s.io/apimachinery/pkg/runtime"
1415
"k8s.io/apimachinery/pkg/types"
@@ -60,6 +61,14 @@ func (r *PipelineReconciler) Reconcile(ctx context.Context, req ctrl.Request) (c
6061
pipeline := &captainv1.Pipeline{}
6162
err := r.Get(ctx, req.NamespacedName, pipeline)
6263
if err != nil {
64+
if apierrors.IsNotFound(err) {
65+
// Request object not found, could have been deleted after reconcile request.
66+
// Return and don't requeue
67+
log.Info("pipeline resource not found")
68+
return reconcile.Result{}, nil
69+
}
70+
// Error reading the object - requeue the request.
71+
log.Error(err, "failed to get pipeline")
6372
return reconcile.Result{}, err
6473
}
6574

0 commit comments

Comments
 (0)