fix(controller): clean up before insert into argo_archived_workflows_…

…labels (#5568) Signed-off-by: BOOK <book78987book@gmail.com>
argoproj · Apr 1, 2021 · ed54f15 · ed54f15
1 parent 2b3655e
commit ed54f15
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/persist/sqldb/workflow_archive.go b/persist/sqldb/workflow_archive.go
@@ -109,6 +109,14 @@ func (r *workflowArchive) ArchiveWorkflow(wf *wfv1.Workflow) error {
  return err
  }
 
+ _, err = sess.
+ DeleteFrom(archiveLabelsTableName).
+ Where(db.Cond{"clustername": r.clusterName}).
+ And(db.Cond{"uid": wf.UID}).
+ Exec()
+ if err != nil {
+ return err
+ }
  // insert the labels
  for key, value := range wf.GetLabels() {
  _, err := sess.Collection(archiveLabelsTableName).