Changes for requeuing the terminal state jobs

Author: creddy123

api/v1alpha1/run_types.go

@@ -64,6 +64,18 @@ func (run *Run) IsSubmitted() bool {
 	return run.Status.Metadata.JobID > 0
 }
 
+// IsTerminated return true if item is in terminal state
+func (run *Run) IsTerminated() bool {
+	if run.Status == nil || run.Status.Metadata.State == nil || run.Status.Metadata.State.LifeCycleState == nil {
+		return false
+	}
+	switch *run.Status.Metadata.State.LifeCycleState {
+	case dbmodels.RunLifeCycleStateTerminated, dbmodels.RunLifeCycleStateSkipped, dbmodels.RunLifeCycleStateInternalError:
+		return true
+	}
+	return false
+}
+
 // RunFinalizerName is the name of the run finalizer
 const RunFinalizerName = "run.finalizers.databricks.microsoft.com"
 

controllers/run_controller.go

@@ -100,7 +100,9 @@ func (r *RunReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
 		}
 		r.Recorder.Event(instance, corev1.EventTypeNormal, "Refreshed", "Object is refreshed")
 	}
-
+	if instance.IsTerminated() {
+		return ctrl.Result{}, nil
+	}
 	return ctrl.Result{RequeueAfter: 30 * time.Second}, nil
 }