fix: Added decompress in retry, resubmit and resume. (#1934)

argoproj · Jan 14, 2020 · f69655a · f69655a
1 parent 1e7ccb5
commit f69655a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/cmd/argo/commands/retry.go b/cmd/argo/commands/retry.go
@@ -28,6 +28,12 @@ func NewRetryCommand() *cobra.Command {
 			if err != nil {
 				log.Fatal(err)
 			}
+
+			err = util.DecompressWorkflow(wf)
+			if err != nil {
+				log.Fatal(err)
+			}
+
 			wf, err = util.RetryWorkflow(kubeClient, wfClient, wf)
 			if err != nil {
 				log.Fatal(err)

diff --git a/workflow/util/util.go b/workflow/util/util.go
@@ -335,6 +335,12 @@ func ResumeWorkflow(wfIf v1alpha1.WorkflowInterface, workflowName string) error
 		if err != nil {
 			return false, err
 		}
+
+		err = DecompressWorkflow(wf)
+		if err != nil {
+			log.Fatal(err)
+		}
+
 		updated := false
 		if wf.Spec.Suspend != nil && *wf.Spec.Suspend {
 			wf.Spec.Suspend = nil
@@ -434,6 +440,10 @@ func FormulateResubmitWorkflow(wf *wfv1.Workflow, memoized bool) (*wfv1.Workflow
 	replaceRegexp := regexp.MustCompile("^" + wf.ObjectMeta.Name)
 	newWF.Status.Nodes = make(map[string]wfv1.NodeStatus)
 	onExitNodeName := wf.ObjectMeta.Name + ".onExit"
+	err := DecompressWorkflow(wf)
+	if err != nil {
+		log.Fatal(err)
+	}
 	for _, node := range wf.Status.Nodes {
 		newNode := node.DeepCopy()
 		if strings.HasPrefix(node.Name, onExitNodeName) {