forked from argoproj/argo-workflows
/
resubmit.go
45 lines (41 loc) · 1.15 KB
/
resubmit.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
package commands
import (
"log"
"os"
"github.com/argoproj/argo/workflow/common"
"github.com/spf13/cobra"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)
func NewResubmitCommand() *cobra.Command {
var (
memoized bool
submitArgs submitFlags
)
var command = &cobra.Command{
Use: "resubmit WORKFLOW",
Short: "resubmit a workflow",
Run: func(cmd *cobra.Command, args []string) {
if len(args) == 0 {
cmd.HelpFunc()(cmd, args)
os.Exit(1)
}
wfClient := InitWorkflowClient()
wf, err := wfClient.Get(args[0], metav1.GetOptions{})
if err != nil {
log.Fatal(err)
}
newWF, err := common.FormulateResubmitWorkflow(wf, memoized)
if err != nil {
log.Fatal(err)
}
_, err = submitWorkflow(newWF, &submitArgs)
if err != nil {
log.Fatal(err)
}
},
}
command.Flags().StringVarP(&submitArgs.output, "output", "o", "", "Output format. One of: name|json|yaml|wide")
command.Flags().BoolVarP(&submitArgs.wait, "wait", "w", false, "wait for the workflow to complete")
command.Flags().BoolVar(&memoized, "memoized", false, "re-use successful steps & outputs from the previous run (experimental)")
return command
}