Create pods for all scenarios.

Author: sivakami

.pipelines/swiftv2-long-running/template/long-running-pipeline-template.yaml

@@ -179,6 +179,14 @@ stages:
                 echo "==> Downloading Go dependencies"
                 go mod download
                 
+                echo "==> Setting up kubeconfig for cluster aks-1"
+                az aks get-credentials \
+                  --resource-group ${{ parameters.resourceGroupName }} \
+                  --name aks-1 \
+                  --file /tmp/aks-1.kubeconfig \
+                  --overwrite-existing \
+                  --admin
+                
                 echo "==> Setting up kubeconfig for cluster aks-2"
                 az aks get-credentials \
                   --resource-group ${{ parameters.resourceGroupName }} \
@@ -187,7 +195,10 @@ stages:
                   --overwrite-existing \
                   --admin
                 
-                echo "==> Verifying cluster connectivity"
+                echo "==> Verifying cluster aks-1 connectivity"
+                kubectl --kubeconfig /tmp/aks-1.kubeconfig get nodes
+                
+                echo "==> Verifying cluster aks-2 connectivity"
                 kubectl --kubeconfig /tmp/aks-2.kubeconfig get nodes
                 
                 echo "==> Running datapath tests"

test/integration/swiftv2/helpers/az_helpers.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"os/exec"
 	"strings"
+	"time"
 )
 
 func runAzCommand(cmd string, args ...string) (string, error) {
@@ -113,3 +114,24 @@ func DeleteNamespace(kubeconfig, namespace string) error {
 	}
 	return nil
 }
+
+// WaitForPodRunning waits for a pod to reach Running state with retries
+func WaitForPodRunning(kubeconfig, namespace, podName string, maxRetries, sleepSeconds int) error {
+	for attempt := 1; attempt <= maxRetries; attempt++ {
+		cmd := exec.Command("kubectl", "--kubeconfig", kubeconfig, "get", "pod", podName, "-n", namespace, "-o", "jsonpath={.status.phase}")
+		out, err := cmd.CombinedOutput()
+
+		if err == nil && strings.TrimSpace(string(out)) == "Running" {
+			fmt.Printf("Pod %s is now Running\n", podName)
+			return nil
+		}
+
+		if attempt < maxRetries {
+			fmt.Printf("Pod %s not running yet (attempt %d/%d), status: %s. Waiting %d seconds...\n",
+				podName, attempt, maxRetries, strings.TrimSpace(string(out)), sleepSeconds)
+			time.Sleep(time.Duration(sleepSeconds) * time.Second)
+		}
+	}
+
+	return fmt.Errorf("pod %s did not reach Running state after %d attempts", podName, maxRetries)
+}