Working to get task to fail.

k8ssandra · Aug 30, 2024 · 2e12fcc · 2e12fcc
1 parent b7d501e
commit 2e12fcc
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/internal/controllers/control/cassandratask_controller.go b/internal/controllers/control/cassandratask_controller.go
@@ -785,6 +785,16 @@ func (r *CassandraTaskReconciler) reconcileEveryPodTask(ctx context.Context, dc
 				return ctrl.Result{}, failed, completed, errMsg, err
 			}
 
+			if taskConfig.SyncFeature != "" {
+				if !features.Supports(taskConfig.SyncFeature) {
+					logger.Error(err, "Pod doesn't support this feature", "Pod", pod, "Feature", taskConfig.SyncFeature)
+					jobStatus.Status = podJobError
+					failed++
+					errMsg = fmt.Sprintf("Pod %s doesn't support %s feature", pod.Name, taskConfig.SyncFeature)
+					return ctrl.Result{}, failed, completed, errMsg, err
+				}
+			}
+
 			jobId := strconv.Itoa(idx)
 
 			// This pod should run next, mark it
@@ -801,16 +811,6 @@ func (r *CassandraTaskReconciler) reconcileEveryPodTask(ctx context.Context, dc
 				return ctrl.Result{}, failed, completed, errMsg, err
 			}
 
-			if taskConfig.SyncFeature != "" {
-				if !features.Supports(taskConfig.SyncFeature) {
-					logger.Error(err, "Pod doesn't support this feature", "Pod", pod, "Feature", taskConfig.SyncFeature)
-					jobStatus.Status = podJobError
-					failed++
-					errMsg = fmt.Sprintf("Pod %s doesn't support %s feature", pod.Name, taskConfig.SyncFeature)
-					return ctrl.Result{}, failed, completed, errMsg, err
-				}
-			}
-
 			pod := pod
 
 			go func() {