Fix initJob restart condition (#187)

* fix issue #94921

* hostNetwork and priorityClassName value from parent for nodeSets

* bump helm chart version

* fix restartPolicy to Never

Author: kobzonega

.github/workflows/run-tests.yml

@@ -63,7 +63,6 @@ jobs:
         uses: golangci/golangci-lint-action@v2
         with:
           version: v1.48.0
-          args: --out-format=colored-line-number
   code-format-check:
     concurrency:
       group: lint-autoformat-${{ github.ref }}

deploy/ydb-operator/Chart.yaml

@@ -15,10 +15,10 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.5.0
+version: 0.5.1
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
 # It is recommended to use it with quotes.
-appVersion: "0.5.0"
+appVersion: "0.5.1"

internal/controllers/storage/init.go

@@ -195,7 +195,14 @@ func (r *Reconciler) initializeStorage(
 		return r.setInitStorageCompleted(ctx, storage, "Storage initialized successfully")
 	}
 
-	if initJob.Status.Failed > 0 {
+	var conditionFailed bool
+	for _, condition := range initJob.Status.Conditions {
+		if condition.Type == batchv1.JobFailed {
+			conditionFailed = true
+			break
+		}
+	}
+	if initJob.Status.Failed == *initJob.Spec.BackoffLimit || conditionFailed {
 		r.Log.Info("Init Job status failed")
 		r.Recorder.Event(
 			storage,

internal/resources/database.go

@@ -281,10 +281,6 @@ func (b *DatabaseBuilder) recastDatabaseNodeSetSpecInline(nodeSetSpecInline *api
 		nodeSetSpec.Tolerations = append(nodeSetSpec.Tolerations, nodeSetSpecInline.Tolerations...)
 	}
 
-	if nodeSetSpecInline.PriorityClassName != nodeSetSpec.PriorityClassName {
-		nodeSetSpec.PriorityClassName = nodeSetSpecInline.PriorityClassName
-	}
-
 	nodeSetSpec.AdditionalLabels = CopyDict(b.Spec.AdditionalLabels)
 	if nodeSetSpecInline.AdditionalLabels != nil {
 		for k, v := range nodeSetSpecInline.AdditionalLabels {

internal/resources/storage.go

@@ -212,10 +212,6 @@ func (b *StorageClusterBuilder) recastStorageNodeSetSpecInline(nodeSetSpecInline
 		nodeSetSpec.Resources = nodeSetSpecInline.Resources
 	}
 
-	if nodeSetSpecInline.HostNetwork != nodeSetSpec.HostNetwork {
-		nodeSetSpec.HostNetwork = nodeSetSpecInline.HostNetwork
-	}
-
 	nodeSetSpec.NodeSelector = CopyDict(b.Spec.NodeSelector)
 	if nodeSetSpecInline.NodeSelector != nil {
 		for k, v := range nodeSetSpecInline.NodeSelector {
@@ -235,10 +231,6 @@ func (b *StorageClusterBuilder) recastStorageNodeSetSpecInline(nodeSetSpecInline
 		nodeSetSpec.TopologySpreadConstraints = append(nodeSetSpec.TopologySpreadConstraints, nodeSetSpecInline.TopologySpreadConstraints...)
 	}
 
-	if nodeSetSpecInline.PriorityClassName != nodeSetSpec.PriorityClassName {
-		nodeSetSpec.PriorityClassName = nodeSetSpecInline.PriorityClassName
-	}
-
 	nodeSetSpec.AdditionalLabels = CopyDict(b.Spec.AdditionalLabels)
 	if nodeSetSpecInline.AdditionalLabels != nil {
 		for k, v := range nodeSetSpecInline.AdditionalLabels {

internal/resources/storage_init_job.go

@@ -40,7 +40,7 @@ func (b *StorageInitJobBuilder) Build(obj client.Object) error {
 		Parallelism:           ptr.Int32(1),
 		Completions:           ptr.Int32(1),
 		ActiveDeadlineSeconds: ptr.Int64(300),
-		BackoffLimit:          ptr.Int32(10),
+		BackoffLimit:          ptr.Int32(3),
 		Template:              b.buildInitJobPodTemplateSpec(),
 	}
 
@@ -91,7 +91,7 @@ func (b *StorageInitJobBuilder) buildInitJobPodTemplateSpec() corev1.PodTemplate
 		Spec: corev1.PodSpec{
 			Containers:    []corev1.Container{b.buildInitJobContainer()},
 			Volumes:       b.buildInitJobVolumes(),
-			RestartPolicy: corev1.RestartPolicyOnFailure,
+			RestartPolicy: corev1.RestartPolicyNever,
 			DNSConfig: &corev1.PodDNSConfig{
 				Searches: dnsConfigSearches,
 			},