zishuo/onepanel
1
0
Fork 0
mirror of https://github.com/onepanelio/onepanel.git synced 2025-10-25 06:20:21 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Grouping relevant podGC Strategy checking and it's subsequent use.

Browse Source
This commit is contained in:
Aleksandr Melnikov
2020-01-17 13:51:17 -08:00
parent aa68061c93
commit f7ab627c29
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
kube/workflow.go
View File

@@ -53,15 +53,6 @@ func (c *Client) create(namespace string, wf *Workflow, opts *WorkflowOptions) (
opts = &WorkflowOptions{} opts = &WorkflowOptions{}
} }
//TODO - Load this data from onepanel config-map or secret
podGCStrategy := env.GetEnv("ARGO_POD_GC_STRATEGY", "OnPodCompletion")
if podGCStrategy != "" {
strategy := PodGCStrategy(podGCStrategy)
opts.PodGCStrategy = &strategy
} else {
strategy := PodGCStrategy("OnPodCompletion")
opts.PodGCStrategy = &strategy
}
if opts.Name != "" { if opts.Name != "" {
wf.ObjectMeta.Name = opts.Name wf.ObjectMeta.Name = opts.Name
} }
@@ -94,6 +85,17 @@ func (c *Client) create(namespace string, wf *Workflow, opts *WorkflowOptions) (
if opts.Labels != nil { if opts.Labels != nil {
wf.ObjectMeta.Labels = *opts.Labels wf.ObjectMeta.Labels = *opts.Labels
} }
//TODO - Load this data from onepanel config-map or secret
podGCStrategy := env.GetEnv("ARGO_POD_GC_STRATEGY", "OnPodCompletion")
if podGCStrategy != "" {
strategy := PodGCStrategy(podGCStrategy)
opts.PodGCStrategy = &strategy
} else {
strategy := PodGCStrategy("OnPodCompletion")
opts.PodGCStrategy = &strategy
}
if wf.Spec.PodGC == nil { if wf.Spec.PodGC == nil {
wf.Spec.PodGC = &wfv1.PodGC{ wf.Spec.PodGC = &wfv1.PodGC{
Strategy: *opts.PodGCStrategy, Strategy: *opts.PodGCStrategy,