Fix retry workflow state (argoproj#1632)

dtaniwaki · sarabala1979 · commit 5d530becae49 · 2019-10-01T10:30:14.000-07:00
diff --git a/workflow/util/util.go b/workflow/util/util.go
@@ -522,6 +522,13 @@ func RetryWorkflow(kubeClient kubernetes.Interface, wfClient v1alpha1.WorkflowIn
 			if err != nil && !apierr.IsNotFound(err) {
 				return nil, errors.InternalWrapError(err)
 			}
+		} else if node.Name == wf.ObjectMeta.Name {
+			newNode := node.DeepCopy()
+			newNode.Phase = wfv1.NodeRunning
+			newNode.Message = ""
+			newNode.FinishedAt = metav1.Time{}
+			newWF.Status.Nodes[newNode.ID] = *newNode
+			continue
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -522,6 +522,13 @@ func RetryWorkflow(kubeClient kubernetes.Interface, wfClient v1alpha1.WorkflowIn`
`522`	`522`	`if err != nil && !apierr.IsNotFound(err) {`
`523`	`523`	`return nil, errors.InternalWrapError(err)`
`524`	`524`	`}`
	`525`	`+ } else if node.Name == wf.ObjectMeta.Name {`
	`526`	`+ newNode := node.DeepCopy()`
	`527`	`+ newNode.Phase = wfv1.NodeRunning`
	`528`	`+ newNode.Message = ""`
	`529`	`+ newNode.FinishedAt = metav1.Time{}`
	`530`	`+ newWF.Status.Nodes[newNode.ID] = *newNode`
	`531`	`+ continue`
`525`	`532`	`}`
`526`	`533`	`}`
`527`	`534`