Expose the backoff limit

Depends-On: openstack-k8s-operators/openstack-ansibleee-operator#356 Signed-off-by: Fabricio Aguiar <[email protected]>
fao89 · May 28, 2024 · 5d42463 · 5d42463
1 parent 9f05094
commit 5d42463
Show file tree

Hide file tree

Showing 8 changed files with 39 additions and 3 deletions.
diff --git a/api/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml b/api/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml
@@ -52,6 +52,10 @@ spec:
                 type: string
               ansibleTags:
                 type: string
+              backoffLimit:
+                default: 6
+                format: int32
+                type: integer
               deploymentRequeueTime:
                 default: 15
                 minimum: 1

diff --git a/api/v1beta1/openstackdataplanedeployment_types.go b/api/v1beta1/openstackdataplanedeployment_types.go
@@ -30,6 +30,11 @@ type OpenStackDataPlaneDeploymentSpec struct {
 	// NodeSets is the list of NodeSets deployed
 	NodeSets []string `json:"nodeSets"`
 
+	// BackoffLimit allows to define the maximum number of retried executions (defaults to 6).
+	// +kubebuilder:default:=6
+	// +operator-sdk:csv:customresourcedefinitions:type=spec,xDescriptors={"urn:alm:descriptor:com.tectonic.ui:number"}
+	BackoffLimit *int32 `json:"backoffLimit,omitempty"`
+
 	// AnsibleTags for ansible execution
 	// +kubebuilder:validation:Optional
 	AnsibleTags string `json:"ansibleTags,omitempty"`

diff --git a/api/v1beta1/zz_generated.deepcopy.go b/api/v1beta1/zz_generated.deepcopy.go
diff --git a/config/crd/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml b/config/crd/bases/dataplane.openstack.org_openstackdataplanedeployments.yaml
@@ -52,6 +52,10 @@ spec:
                 type: string
               ansibleTags:
                 type: string
+              backoffLimit:
+                default: 6
+                format: int32
+                type: integer
               deploymentRequeueTime:
                 default: 15
                 minimum: 1

diff --git a/config/manifests/bases/dataplane-operator.clusterserviceversion.yaml b/config/manifests/bases/dataplane-operator.clusterserviceversion.yaml
@@ -20,6 +20,13 @@ spec:
       displayName: OpenStack Data Plane Deployments
       kind: OpenStackDataPlaneDeployment
       name: openstackdataplanedeployments.dataplane.openstack.org
+      specDescriptors:
+      - description: BackoffLimit allows to define the maximum number of retried executions
+          (defaults to 6).
+        displayName: Backoff Limit
+        path: backoffLimit
+        x-descriptors:
+        - urn:alm:descriptor:com.tectonic.ui:number
       statusDescriptors:
       - description: Conditions
         displayName: Conditions

diff --git a/docs/assemblies/custom_resources.adoc b/docs/assemblies/custom_resources.adoc
@@ -658,6 +658,11 @@ OpenStackDataPlaneDeploymentSpec defines the desired state of OpenStackDataPlane
 | []string
 | true
 
+| backoffLimit
+| BackoffLimit allows to define the maximum number of retried executions (defaults to 6).
+| *int32
+| false
+
 | ansibleTags
 | AnsibleTags for ansible execution
 | string

diff --git a/pkg/deployment/deployment.go b/pkg/deployment/deployment.go
@@ -205,12 +205,17 @@ func (d *Deployer) ConditionalDeploy(
 		}
 
 		if ansibleEE.Status.JobStatus == ansibleeev1.JobStatusFailed {
+			errorMsg := fmt.Sprintf("execution.name %s execution.namespace %s execution.status.jobstatus: %s", ansibleEE.Name, ansibleEE.Namespace, ansibleEE.Status.JobStatus)
+			ansibleCondition := ansibleEE.Status.Conditions.Get(condition.JobReadyCondition)
+			if ansibleCondition.Reason == condition.JobReasonBackoffLimitExceeded {
+				errorMsg = fmt.Sprintf("backoff limit reached for execution.name %s execution.namespace %s execution.status.jobstatus: %s", ansibleEE.Name, ansibleEE.Namespace, ansibleEE.Status.JobStatus)
+			}
 			log.Info(fmt.Sprintf("Condition %s error", readyCondition))
-			err = fmt.Errorf("execution.name %s Execution.namespace %s Execution.status.jobstatus: %s", ansibleEE.Name, ansibleEE.Namespace, ansibleEE.Status.JobStatus)
+			err = fmt.Errorf(errorMsg)
 			nsConditions.Set(condition.FalseCondition(
 				readyCondition,
-				condition.ErrorReason,
-				condition.SeverityError,
+				ansibleCondition.Reason,
+				ansibleCondition.Severity,
 				readyErrorMessage,
 				err.Error()))
 		}

diff --git a/pkg/util/ansible_execution.go b/pkg/util/ansible_execution.go
@@ -107,6 +107,7 @@ func AnsibleExecution(
 		if len(service.Spec.Playbook) > 0 {
 			ansibleEE.Spec.Playbook = service.Spec.Playbook
 		}
+		ansibleEE.Spec.BackoffLimit = deployment.Spec.BackoffLimit
 
 		// If we have a service that ought to be deployed everywhere
 		// substitute the existing play target with 'all'