feat: add retry API for archived workflows. Fixes #7906

api/jsonschema/schema.json

@@ -6584,6 +6584,26 @@
  },
  "type": "object"
  },
+ "io.argoproj.workflow.v1alpha1.RetryArchivedWorkflowRequest": {
+ "properties": {
+ "name": {
+ "type": "string"
+ },
+ "namespace": {
+ "type": "string"
+ },
+ "nodeFieldSelector": {
+ "type": "string"
+ },
+ "restartSuccessful": {
+ "type": "boolean"
+ },
+ "uid": {
+ "type": "string"
+ }
+ },
+ "type": "object"
+ },
  "io.argoproj.workflow.v1alpha1.RetryNodeAntiAffinity": {
  "description": "RetryNodeAntiAffinity is a placeholder for future expansion, only empty nodeAntiAffinity is allowed. In order to prevent running steps on the same host, it uses \"kubernetes.io/hostname\".",
  "type": "object"

api/openapi-spec/swagger.json

@@ -204,6 +204,50 @@
  }
  }
  },
+ "/api/v1/archived-workflows/{namespace}/{uid}/retry": {
+ "put": {
+ "tags": [
+ "ArchivedWorkflowService"
+ ],
+ "operationId": "ArchivedWorkflowService_RetryArchivedWorkflow",
+ "parameters": [
+ {
+ "type": "string",
+ "name": "namespace",
+ "in": "path",
+ "required": true
+ },
+ {
+ "type": "string",
+ "name": "uid",
+ "in": "path",
+ "required": true
+ },
+ {
+ "name": "body",
+ "in": "body",
+ "required": true,
+ "schema": {
+ "$ref": "#/definitions/io.argoproj.workflow.v1alpha1.RetryArchivedWorkflowRequest"
+ }
+ }
+ ],
+ "responses": {
+ "200": {
+ "description": "A successful response.",
+ "schema": {
+ "$ref": "#/definitions/io.argoproj.workflow.v1alpha1.Workflow"
+ }
+ },
+ "default": {
+ "description": "An unexpected error response.",
+ "schema": {
+ "$ref": "#/definitions/grpc.gateway.runtime.Error"
+ }
+ }
+ }
+ }
+ },
  "/api/v1/archived-workflows/{uid}": {
  "get": {
  "tags": [
@@ -10846,6 +10890,26 @@
  }
  }
  },
+ "io.argoproj.workflow.v1alpha1.RetryArchivedWorkflowRequest": {
+ "type": "object",
+ "properties": {
+ "name": {
+ "type": "string"
+ },
+ "namespace": {
+ "type": "string"
+ },
+ "nodeFieldSelector": {
+ "type": "string"
+ },
+ "restartSuccessful": {
+ "type": "boolean"
+ },
+ "uid": {
+ "type": "string"
+ }
+ }
+ },
  "io.argoproj.workflow.v1alpha1.RetryNodeAntiAffinity": {
  "description": "RetryNodeAntiAffinity is a placeholder for future expansion, only empty nodeAntiAffinity is allowed. In order to prevent running steps on the same host, it uses \"kubernetes.io/hostname\".",
  "type": "object"

persist/sqldb/null_workflow_archive.go

@@ -17,6 +17,10 @@ func (r *nullWorkflowArchive) IsEnabled() bool {
  return false
 }
 
+func (r *nullWorkflowArchive) ValidateWorkflow(wf *wfv1.Workflow) error {
+ return nil
+}
+
 func (r *nullWorkflowArchive) ArchiveWorkflow(*wfv1.Workflow) error {
  return nil
 }

persist/sqldb/workflow_archive.go

@@ -58,6 +58,7 @@ type WorkflowArchive interface {
  IsEnabled() bool
  ListWorkflowsLabelKeys() (*wfv1.LabelKeys, error)
  ListWorkflowsLabelValues(key string) (*wfv1.LabelValues, error)
+ ValidateWorkflow(wf *wfv1.Workflow) error
 }
 
 type workflowArchive struct {
@@ -72,6 +73,10 @@ func (r *workflowArchive) IsEnabled() bool {
  return true
 }
 
+func (r *workflowArchive) ValidateWorkflow(wf *wfv1.Workflow) error {
+ return r.instanceIDService.Validate(wf)
+}
+
 // NewWorkflowArchive returns a new workflowArchive
 func NewWorkflowArchive(session sqlbuilder.Database, clusterName, managedNamespace string, instanceIDService instanceid.Service) WorkflowArchive {
  return &workflowArchive{session: session, clusterName: clusterName, managedNamespace: managedNamespace, instanceIDService: instanceIDService, dbType: dbTypeFor(session)}

pkg/apiclient/http1/archived-workflows-service-client.go

@@ -46,3 +46,8 @@ func (h ArchivedWorkflowsServiceClient) ListArchivedWorkflowLabelValues(_ contex
  out := &wfv1.LabelValues{}
  return out, h.Get(in, out, "/api/v1/archived-workflows-label-values")
 }
+
+func (h ArchivedWorkflowsServiceClient) RetryArchivedWorkflow(_ context.Context, in *workflowarchivepkg.RetryArchivedWorkflowRequest, _ ...grpc.CallOption) (*wfv1.Workflow, error) {
+ out := &wfv1.Workflow{}
+ return out, h.Get(in, out, "/api/v1/archived-workflows/{namespace}/{uid}/retry")
+}