chore: pick container ready pods

Signed-off-by: Rory Z <[email protected]>
emqx · Apr 9, 2024 · d1191ac · d1191ac
1 parent aed1400
commit d1191ac
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 8 deletions.
diff --git a/.github/workflows/cts.yaml b/.github/workflows/cts.yaml
@@ -135,7 +135,7 @@ jobs:
           repository: ghcr.io/${{ github.repository }}
           tag: ${{ github.ref_name }}
       - name: Deploy emqx
-        timeout-minutes: 5
+        timeout-minutes: 10
         uses: ./.github/actions/deploy-emqx
         with:
           kind: ${{ matrix.emqx[0] }}

diff --git a/controllers/apps/v2beta1/emqx_controller.go b/controllers/apps/v2beta1/emqx_controller.go
@@ -121,6 +121,7 @@ func (r *EMQXReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.
 
 	for _, subReconciler := range []subReconciler{
 		&addBootstrap{r},
+		&updatePodConditions{r},
 		&updateStatus{r},
 		&addCore{r},
 		&addRepl{r},
@@ -198,13 +199,17 @@ func newRequester(ctx context.Context, k8sClient client.Client, instance *appsv2
 	})
 
 	for _, pod := range podList.Items {
-		if pod.GetDeletionTimestamp() == nil && pod.Status.Phase == corev1.PodRunning && pod.Status.PodIP != "" {
-			return &innerReq.Requester{
-				Schema:   schema,
-				Host:     net.JoinHostPort(pod.Status.PodIP, port),
-				Username: username,
-				Password: password,
-			}, nil
+		if pod.GetDeletionTimestamp() == nil && pod.Status.PodIP != "" {
+			for _, cond := range pod.Status.Conditions {
+				if cond.Type == corev1.ContainersReady && cond.Status == corev1.ConditionTrue {
+					return &innerReq.Requester{
+						Schema:   schema,
+						Host:     net.JoinHostPort(pod.Status.PodIP, port),
+						Username: username,
+						Password: password,
+					}, nil
+				}
+			}
 		}
 	}