feat: add owner references to DGDR-created ConfigMaps (#7782)

Signed-off-by: Hannah Zhang <hannahz@nvidia.com>

deploy/operator/internal/controller/dynamographdeploymentrequest_controller.go

@@ -169,6 +169,13 @@ metadata:
     dgdr.nvidia.com/name: {{.DGDRName}}
     dgdr.nvidia.com/namespace: {{.Namespace}}
     nvidia.com/managed-by: dynamo-operator
+  ownerReferences:
+  - apiVersion: nvidia.com/v1beta1
+    kind: DynamoGraphDeploymentRequest
+    name: {{.DGDRName}}
+    uid: {{.DGDRuid}}
+    blockOwnerDeletion: true
+    controller: true
 data:
   phase: "$PHASE"
   message: "$MESSAGE"
@@ -265,6 +272,13 @@ metadata:
     dgdr.nvidia.com/name: {{.DGDRName}}
     dgdr.nvidia.com/namespace: {{.Namespace}}
     nvidia.com/managed-by: dynamo-operator
+  ownerReferences:
+  - apiVersion: nvidia.com/v1beta1
+    kind: DynamoGraphDeploymentRequest
+    name: {{.DGDRName}}
+    uid: {{.DGDRuid}}
+    blockOwnerDeletion: true
+    controller: true
 data:
   phase: "$FINAL_PHASE"
   message: "$FINAL_MESSAGE"
@@ -946,16 +960,14 @@ func (r *DynamoGraphDeploymentRequestReconciler) createAdditionalResources(ctx c
 		cm.Labels[nvidiacomv1beta1.LabelDGDRNamespace] = dgdr.Namespace
 		cm.Labels[nvidiacomv1beta1.LabelManagedBy] = nvidiacomv1beta1.LabelValueDynamoOperator
 
-		// Create the ConfigMap
-		if err := r.Create(ctx, cm); err != nil {
-			if apierrors.IsAlreadyExists(err) {
-				logger.Info("ConfigMap already exists, skipping", "name", cm.Name)
-			} else {
-				return fmt.Errorf("failed to create ConfigMap %s: %w", cm.Name, err)
-			}
-		} else {
-			logger.Info("Created ConfigMap from profiling output", "name", cm.Name, "namespace", targetNamespace)
+		// Use SyncResource to create/update the ConfigMap with owner reference and change detection
+		_, _, err := commonController.SyncResource(ctx, r, dgdr, func(ctx context.Context) (*corev1.ConfigMap, bool, error) {
+			return cm, false, nil
+		})
+		if err != nil {
+			return fmt.Errorf("failed to sync ConfigMap %s: %w", cm.Name, err)
 		}
+		logger.Info("Synced ConfigMap from profiling output", "name", cm.Name, "namespace", targetNamespace)
 	}
 
 	if resourceCount > 0 {
@@ -1270,6 +1282,7 @@ func (r *DynamoGraphDeploymentRequestReconciler) createProfilingJob(ctx context.
 			"ConfigMapName": outputConfigMapName,
 			"Namespace":     dgdr.Namespace,
 			"DGDRName":      dgdr.Name,
+			"DGDRuid":       string(dgdr.UID),
 		})
 		if err != nil {
 			return nil, false, fmt.Errorf("failed to execute sidecar script template: %w", err)