Fix tests

tests/assets/single.yaml

@@ -88,7 +88,7 @@ write_files:
             envFrom:
             - configMapRef:
                 name: default-controller-env
-            image: rancher/system-upgrade-controller:v0.9.1
+            image: quay.io/jimmykarily/system-upgrade-controller:v0.9.1
             imagePullPolicy: IfNotPresent
             name: system-upgrade-controller
             volumeMounts:

tests/decentralized_test.go

@@ -197,14 +197,17 @@ var _ = Describe("kairos decentralized k8s test", Label("decentralized-k8s"), fu
 				vm.Reboot(1200)
 				out := ""
 				Eventually(func() string {
-					vm.Sudo(`curl -X POST http://localhost:8080/api/dns --header "Content-Type: application/json" -d '{ "Regex": "foo.bar", "Records": { "A": "2.2.2.2" } }'`)
-					out, _ = vm.Sudo("ping -c 1 foo.bar")
+					var err error
+					out, err = vm.Sudo(`curl -X POST http://localhost:8080/api/dns --header "Content-Type: application/json" -d '{ "Regex": "foo.bar", "Records": { "A": "2.2.2.2" } }'`)
+					Expect(err).ToNot(HaveOccurred(), out)
+
+					out, _ = vm.Sudo("dig +short foo.bar")
 					return out
-				}, 900*time.Second, 10*time.Second).Should(ContainSubstring("2.2.2.2"), out)
+				}, 900*time.Second, 10*time.Second).Should(Equal("2.2.2.2"), out)
 				Eventually(func() string {
-					out, _ = vm.Sudo("ping -c 1 google.com")
+					out, _ = vm.Sudo("dig +short google.com")
 					return out
-				}, 900*time.Second, 10*time.Second).Should(ContainSubstring("64 bytes from"), out)
+				}, 900*time.Second, 10*time.Second).ShouldNot(BeEmpty(), out)
 			}
 		})
 

tests/upgrade_latest_k8s_test.go

@@ -139,6 +139,7 @@ var _ = Describe("k3s upgrade test from k8s", Label("upgrade-latest-with-kuberne
 		By("wait system-upgrade-controller")
 		Eventually(func() string {
 			out, _ := kubectl(vm, "get pods -A")
+			fmt.Printf("out = %+v\n", out)
 			return out
 		}, 900*time.Second, 10*time.Second).Should(ContainSubstring("system-upgrade-controller"))
 
@@ -163,7 +164,7 @@ var _ = Describe("k3s upgrade test from k8s", Label("upgrade-latest-with-kuberne
 
 		By("checking upgraded version")
 		Eventually(func() string {
-			out, _ = kubectl(vm, "get pods -A")
+			out, _ = kubectl(vm, "describe jobs -A")
 			version, err := vm.Sudo(getVersionCmd)
 			if err != nil || !strings.Contains(version, "v") {
 				// If we met error, keep going with the Eventually