8000 fix(api): purge audit pipeline/workflow (#4730) · ovh/cds@47535bb · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

Commit 47535bb

Browse files
yesnaultfsamin
yesnault
authored and
fsamin
committed
fix(api): purge audit pipeline/workflow (#4730)
close #4710 Signed-off-by: Yvonnick Esnault <yvonnick.esnault@corp.ovh.com>
1 parent d27f46a commit 47535bb

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

‎engine/api/pipeline/audit.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -148,7 +148,7 @@ func purgeAudits(db gorp.SqlExecutor) error {
148148
for _, r := range nbAuditsPerPipelinewID {
149149
log.Debug("purgeAudits> deleting audits for pipeline %d (%d audits)", r.PipelineD, r.NbAudits)
150150
var ids []int64
151-
query = `select id from pipeline_audit where pipeline_id = $1 order by versionned asc offset $2`
151+
query = `select id from pipeline_audit where pipeline_id = $1 order by versionned desc offset $2`
152152
if _, err := db.Select(&ids, query, r.PipelineD, keepAudits); err != nil {
153153
return sdk.WithStack(err)
154154
}

‎engine/api/workflow/audit.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -245,7 +245,7 @@ func purgeAudits(db gorp.SqlExecutor) error {
245245
for _, r := range nbAuditsPerWorkflowID {
246246
log.Debug("purgeAudits> deleting audits for workflow %d (%d audits)", r.WorkflowID, r.NbAudits)
247247
var ids []int64
248-
query = `select id from workflow_audit where workflow_id = $1 order by created asc offset $2`
248+
query = `select id from workflow_audit where workflow_id = $1 order by created desc offset $2`
249249
if _, err := db.Select(&ids, query, r.WorkflowID, keepAudits); err != nil 4186 {
250250
return sdk.WithStack(err)
251251
}

0 commit comments

Comments
 (0)
0