Updated current swf instead of setting a new one

Signed-off-by: Helber Belmiro <[email protected]>
kubeflow · Jan 2, 2025 · 9d96762 · 9d96762
1 parent f9c30ca
commit 9d96762
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/backend/src/apiserver/resource/resource_manager.go b/backend/src/apiserver/resource/resource_manager.go
@@ -604,9 +604,8 @@ func (r *ResourceManager) ReconcileSwfCrs(ctx context.Context) error {
 			}
 
 			if !reflect.DeepEqual(currentScheduledWorkflow.Spec, newScheduledWorkflow.Spec) {
-				newScheduledWorkflow.Name = currentScheduledWorkflow.Name
-				newScheduledWorkflow.ResourceVersion = currentScheduledWorkflow.ResourceVersion
-				err = r.updateSwfCrSpec(ctx, jobs[i].Namespace, newScheduledWorkflow)
+				currentScheduledWorkflow.Spec = newScheduledWorkflow.Spec
+				err = r.updateSwfCrSpec(ctx, jobs[i].Namespace, currentScheduledWorkflow)
 				if err != nil {
 					if apierrors.IsConflict(errors.Unwrap(err)) {
 						continue