feat: Append previous workflow name as label to resubmitted workflow (a…

…rgoproj#3261)

workflow/common/common.go

@@ -57,6 +57,8 @@ const (
  LabelKeyWorkflow = workflow.WorkflowFullName + "/workflow"
  // LabelKeyPhase is a label applied to workflows to indicate the current phase of the workflow (for filtering purposes)
  LabelKeyPhase = workflow.WorkflowFullName + "/phase"
+ // LabelKeyPreviousWorkflowName is a label applied to resubmitted workflows
+ LabelKeyPreviousWorkflowName = workflow.WorkflowFullName + "/resubmitted-from-workflow"
  // LabelKeyCronWorkflow is a label applied to Workflows that are started by a CronWorkflow
  LabelKeyCronWorkflow = workflow.WorkflowFullName + "/cron-workflow"
  // LabelKeyWorkflowTemplate is a label applied to Workflows that are submitted from Workflowtemplate

workflow/util/util.go

@@ -493,15 +493,18 @@ func FormulateResubmitWorkflow(wf *wfv1.Workflow, memoized bool) (*wfv1.Workflow
 
  // carry over user labels and annotations from previous workflow.
  // skip any argoproj.io labels except for the controller instanceID label.
+ if newWF.ObjectMeta.Labels == nil {
+ newWF.ObjectMeta.Labels = make(map[string]string)
+ }
  for key, val := range wf.ObjectMeta.Labels {
  if strings.HasPrefix(key, workflow.WorkflowFullName+"/") && key != common.LabelKeyControllerInstanceID {
  continue
  }
- if newWF.ObjectMeta.Labels == nil {
- newWF.ObjectMeta.Labels = make(map[string]string)
- }
  newWF.ObjectMeta.Labels[key] = val
  }
+ // Append an additional label so it's easy for user to see the
+ // name of the original workflow that has been resubmitted.
+ newWF.ObjectMeta.Labels[common.LabelKeyPreviousWorkflowName] = wf.ObjectMeta.Name
  for key, val := range wf.ObjectMeta.Annotations {
  if newWF.ObjectMeta.Annotations == nil {
  newWF.ObjectMeta.Annotations = make(map[string]string)