@@ -132,7 +132,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
132132
133133 // Index the Kustomizations by the Bucket references they (may) point at.
134134 if err := mgr .GetCache ().IndexField (ctx , & kustomizev1.Kustomization {}, bucketIndexKey ,
135- r .indexBy (sourcev1b2 .BucketKind )); err != nil {
135+ r .indexBy (sourcev1 .BucketKind )); err != nil {
136136 return fmt .Errorf ("failed setting index fields: %w" , err )
137137 }
138138
@@ -155,7 +155,7 @@ func (r *KustomizationReconciler) SetupWithManager(ctx context.Context, mgr ctrl
155155 builder .WithPredicates (SourceRevisionChangePredicate {}),
156156 ).
157157 Watches (
158- & sourcev1b2 .Bucket {},
158+ & sourcev1 .Bucket {},
159159 handler .EnqueueRequestsFromMapFunc (r .requestsForRevisionChangeOf (bucketIndexKey )),
160160 builder .WithPredicates (SourceRevisionChangePredicate {}),
161161 ).
@@ -561,8 +561,8 @@ func (r *KustomizationReconciler) getSource(ctx context.Context,
561561 return src , fmt .Errorf ("unable to get source '%s': %w" , namespacedName , err )
562562 }
563563 src = & repository
564- case sourcev1b2 .BucketKind :
565- var bucket sourcev1b2 .Bucket
564+ case sourcev1 .BucketKind :
565+ var bucket sourcev1 .Bucket
566566 err := r .Client .Get (ctx , namespacedName , & bucket )
567567 if err != nil {
568568 if apierrors .IsNotFound (err ) {
0 commit comments