@@ -35,7 +35,6 @@ import (
3535 "sigs.k8s.io/controller-runtime/pkg/client"
3636 "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil"
3737 "sigs.k8s.io/controller-runtime/pkg/log"
38- "sigs.k8s.io/kueue/pkg/podset"
3938)
4039
4140func parseComponent (raw []byte , expectedNamespace string ) (* unstructured.Unstructured , error ) {
@@ -241,7 +240,7 @@ func (r *AppWrapperReconciler) createComponent(ctx context.Context, aw *awv1beta
241240 if len (toInject .Annotations ) > 0 {
242241 existing := toMap (metadata ["annotations" ])
243242 if err := utilmaps .HaveConflict (existing , toInject .Annotations ); err != nil {
244- return podset . BadPodSetsUpdateError ( " annotations" , err ), true
243+ return fmt . Errorf ( "conflict updating annotations: %w " , err ), true
245244 }
246245 metadata ["annotations" ] = utilmaps .MergeKeepFirst (existing , toInject .Annotations )
247246 }
@@ -250,15 +249,15 @@ func (r *AppWrapperReconciler) createComponent(ctx context.Context, aw *awv1beta
250249 mergedLabels := utilmaps .MergeKeepFirst (toInject .Labels , awLabels )
251250 existing := toMap (metadata ["labels" ])
252251 if err := utilmaps .HaveConflict (existing , mergedLabels ); err != nil {
253- return podset . BadPodSetsUpdateError ( " labels" , err ), true
252+ return fmt . Errorf ( "conflict updating labels: %w " , err ), true
254253 }
255254 metadata ["labels" ] = utilmaps .MergeKeepFirst (existing , mergedLabels )
256255
257256 // NodeSelectors
258257 if len (toInject .NodeSelector ) > 0 {
259258 existing := toMap (spec ["nodeSelector" ])
260259 if err := utilmaps .HaveConflict (existing , toInject .NodeSelector ); err != nil {
261- return podset . BadPodSetsUpdateError ( " nodeSelector" , err ), true
260+ return fmt . Errorf ( "conflict updating nodeSelector: %w " , err ), true
262261 }
263262 spec ["nodeSelector" ] = utilmaps .MergeKeepFirst (existing , toInject .NodeSelector )
264263 }
0 commit comments