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

Removing unused functions.

Browse Source
This commit is contained in:
Aleksandr Melnikov
2020-05-22 15:57:00 -07:00
parent cd4f429559
commit e405ccdf04
1 changed files with 0 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
pkg/cron_workflow.go
View File

@@ -546,19 +546,6 @@ func (c *Client) ArchiveCronWorkflow(namespace, uid string) (err error) {
return
}
func unmarshalCronWorkflows(cwfBytes []byte, strict bool) (cwfs wfv1.CronWorkflow, err error) {
var cwf wfv1.CronWorkflow
var jsonOpts []argojson.JSONOpt
if strict {
jsonOpts = append(jsonOpts, argojson.DisallowUnknownFields)
}
err = argojson.Unmarshal(cwfBytes, &cwf, jsonOpts...)
if err == nil {
return cwf, nil
}
return
}
func (c *Client) cronWorkflowSelectBuilder(namespace string, workflowTemplateUid string) sq.SelectBuilder {
sb := c.cronWorkflowSelectBuilderNoColumns(namespace, workflowTemplateUid).
Columns(getCronWorkflowColumns("wtv.version")...)
@@ -652,27 +639,3 @@ func getCronWorkflowColumns(extraColumns ...string) []string {
return results
}
func (c *Client) selectCronWorkflowWithWorkflowTemplateVersion(namespace, uid string, extraColumns ...string) (error, *CronWorkflow) {
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").
Where(sq.Eq{
"wt.namespace": namespace,
"cw.name": uid,
"cw.is_archived": false,
}).
ToSql()
if err != nil {
return err, nil
}
cronWorkflow := &CronWorkflow{}
if err = c.DB.Get(cronWorkflow, query, args...); err != nil {
return err, nil
}
return nil, cronWorkflow
}