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

Refactored per https://github.com/onepanelio/core/pull/226#discussion_r428964039.

Browse Source
This commit is contained in:
Aleksandr Melnikov
2020-05-22 15:28:59 -07:00
parent 472c50b9d7
commit 7ec544550b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/cron_workflow.go
View File

@@ -561,7 +561,7 @@ func unmarshalCronWorkflows(cwfBytes []byte, strict bool) (cwfs wfv1.CronWorkflo
func (c *Client) cronWorkflowSelectBuilder(namespace string, workflowTemplateUid string) sq.SelectBuilder {
sb := c.cronWorkflowSelectBuilderNoColumns(namespace, workflowTemplateUid).
Columns(cronWorkflowColumns("wtv.version")...)
Columns(getCronWorkflowColumns("wtv.version")...)
return sb
}
@@ -658,7 +658,7 @@ func (c *Client) GetCronWorkflowStatisticsForTemplates(workflowTemplates ...*Wor
return
}
func cronWorkflowColumns(extraColumns ...string) []string {
func getCronWorkflowColumns(extraColumns ...string) []string {
results := []string{"cw.id", "cw.created_at", "cw.uid", "cw.name", "cw.workflow_template_version_id", "cw.manifest", "cw.namespace"}
for _, str := range extraColumns {
@@ -669,7 +669,7 @@ func cronWorkflowColumns(extraColumns ...string) []string {
}
func (c *Client) SelectCronWorkflowWithWorkflowTemplateVersion(namespace, uid string, extraColumns ...string) (error, *CronWorkflow) {
query, args, err := sb.Select(cronWorkflowColumns(extraColumns...)...).
query, args, err := sb.Select(getCronWorkflowColumns(extraColumns...)...).
From("cron_workflows cw").
Join("workflow_template_versions wtv ON wtv.id = cw.workflow_template_version_id").
Join("workflow_templates wt ON wt.id = wtv.workflow_template_id").