update opj status in releaseTargets (#280)

KusionStack · Sep 19, 2024 · 906dbe2 · 906dbe2
1 parent e43c4c0
commit 906dbe2
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/controllers/operationjob/operationjob_manager.go b/pkg/controllers/operationjob/operationjob_manager.go
@@ -235,7 +235,7 @@ func (r *ReconcileOperationJob) releaseTargets(ctx context.Context, operationJob
 		return err
 	}
 
-	_, err = controllerutils.SlowStartBatch(len(candidates), controllerutils.SlowStartInitialBatchSize, false, func(i int, _ error) error {
+	_, releaseErr := controllerutils.SlowStartBatch(len(candidates), controllerutils.SlowStartInitialBatchSize, false, func(i int, _ error) error {
 		candidate := candidates[i]
 		err := actionHandler.ReleaseTarget(ctx, candidate, operationJob)
 		// mark candidate as failed if not finished
@@ -249,7 +249,9 @@ func (r *ReconcileOperationJob) releaseTargets(ctx context.Context, operationJob
 		}
 		return err
 	})
-	return err
+	operationJob.Status = r.calculateStatus(operationJob, candidates)
+	updateErr := r.updateStatus(ctx, operationJob)
+	return controllerutils.AggregateErrors([]error{releaseErr, updateErr})
 }
 
 func (r *ReconcileOperationJob) cleanCandidateOpsLifecycle(ctx context.Context, forced bool, candidate *OpsCandidate, operationJob *appsv1alpha1.OperationJob) error {