Skip to content

Commit c4742f4

Browse files
Merge pull request opendatahub-io#124 from HumairAK/fix_statuses
Fix statuses
2 parents fe12ad9 + 4c7dcac commit c4742f4

File tree

1 file changed

+13
-9
lines changed

1 file changed

+13
-9
lines changed

controllers/dspipeline_controller.go

Lines changed: 13 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -127,6 +127,9 @@ func (r *DSPAReconciler) isDeploymentAvailable(ctx context.Context, dspa *dspav1
127127

128128
err := r.Get(ctx, types.NamespacedName{Name: component, Namespace: dspa.Namespace}, found)
129129
if err == nil {
130+
if found.Spec.Replicas != nil && *found.Spec.Replicas == 0 {
131+
return false
132+
}
130133
for _, s := range found.Status.Conditions {
131134
if s.Type == "Available" && s.Status == corev1.ConditionTrue {
132135
return true
@@ -318,36 +321,37 @@ func (r *DSPAReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.
318321
func (r *DSPAReconciler) PublishMetrics(dspa *dspav1alpha1.DataSciencePipelinesApplication,
319322
apiServerReady, persistenceAgentReady, scheduledWorkflowReady,
320323
crReady metav1.Condition) {
321-
r.Log.Info("Publishing Ready Metrics")
324+
log := r.Log.WithValues("namespace", dspa.Namespace).WithValues("dspa_name", dspa.Name)
325+
log.Info("Publishing Ready Metrics")
322326
if apiServerReady.Status == metav1.ConditionTrue {
323-
r.Log.Info("APIServer Ready")
327+
log.Info("APIServer Ready")
324328
APIServerReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(1)
325329
} else {
326-
r.Log.Info("APIServer Not Ready")
330+
log.Info("APIServer Not Ready")
327331
APIServerReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(0)
328332
}
329333

330334
if persistenceAgentReady.Status == metav1.ConditionTrue {
331-
r.Log.Info("PersistanceAgent Ready")
335+
log.Info("PersistanceAgent Ready")
332336
PersistenceAgentReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(1)
333337
} else {
334-
r.Log.Info("PersistanceAgent Not Ready")
338+
log.Info("PersistanceAgent Not Ready")
335339
PersistenceAgentReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(0)
336340
}
337341

338342
if scheduledWorkflowReady.Status == metav1.ConditionTrue {
339-
r.Log.Info("ScheduledWorkflow Ready")
343+
log.Info("ScheduledWorkflow Ready")
340344
ScheduledWorkflowReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(1)
341345
} else {
342-
r.Log.Info("ScheduledWorkflow Not Ready")
346+
log.Info("ScheduledWorkflow Not Ready")
343347
ScheduledWorkflowReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(0)
344348
}
345349

346350
if crReady.Status == metav1.ConditionTrue {
347-
r.Log.Info("CR Fully Ready")
351+
log.Info("CR Fully Ready")
348352
CrReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(1)
349353
} else {
350-
r.Log.Info("CR Not Ready")
354+
log.Info("CR Not Ready")
351355
CrReadyMetric.WithLabelValues(dspa.Name, dspa.Namespace).Set(0)
352356
}
353357
}

0 commit comments

Comments
 (0)