fix multi-loader CI

Signed-off-by: Leonid Kondrashov <leo.kondrashov@gmail.com>

Author: leokondrashov

.github/actions/ci_knative_setup/action.yml

@@ -42,4 +42,4 @@ runs:
         kubectl patch configmap -n knative-serving config-domain -p "{\"data\": {\"$KNATIVE_DOMAIN\": \"\"}}"
         kubectl patch configmap -n knative-serving config-autoscaler -p "{\"data\": {\"allow-zero-initial-scale\": \"true\"}}"
         kubectl patch configmap -n knative-serving config-features -p "{\"data\": {\"kubernetes.podspec-affinity\": \"enabled\"}}"
-        kubectl label node knative-control-plane loader-nodetype=worker
+        kubectl label node knative-control-plane loader-nodetype=singlenode

.github/workflows/e2e_multi_loader.yaml

@@ -35,7 +35,7 @@ jobs:
         run: bash ./scripts/setup/setup_multi_test_trace.sh
 
       - name: Build and run multi-loader
-        run: go run tools/multi_loader/multi_loader.go --multiLoaderConfigPath tools/multi_loader/multi_loader_config.json
+        run: go run tools/multi_loader/multi_loader.go --multiLoaderConfigPath tools/multi_loader/multi_loader_config.json --verbosity debug
 
       - name: Check multi_loader output
         run: |
@@ -110,7 +110,7 @@ jobs:
           echo "multi_loader_config.json modified successfully"
 
       - name: Build and run multi-loader
-        run: go run tools/multi_loader/multi_loader.go --multiLoaderConfigPath tools/multi_loader/multi_loader_config.json
+        run: go run tools/multi_loader/multi_loader.go --multiLoaderConfigPath tools/multi_loader/multi_loader_config.json --verbosity debug
 
       - name: Check multi_loader output
         run: |

pkg/common/validators.go

@@ -1,28 +1,13 @@
 package common
 
 import (
-	"bytes"
 	"net"
 	"os"
-	"os/exec"
 	"slices"
 
 	log "github.com/sirupsen/logrus"
 )
 
-func CheckNode(node string) {
-	if !IsValidIP(node) {
-		log.Fatal("Invalid IP address for node ", node)
-	}
-	cmd := exec.Command("ssh", "-oStrictHostKeyChecking=no", "-p", "22", node, "exit")
-	// -oStrictHostKeyChecking=no -p 22
-	out, err := cmd.CombinedOutput()
-	if bytes.Contains(out, []byte("Permission denied")) || err != nil {
-		log.Error(string(out))
-		log.Fatal("Failed to connect to node ", node)
-	}
-}
-
 func CheckPath(path string) {
 	if path == "" {
 		return

tools/multi_loader/common/utils.go

@@ -180,10 +180,7 @@ func DetermineNodesIPs(multiLoaderConfig *types.MultiLoaderConfiguration) {
 
 	switch {
 	case IsKinD():
-		nodeIP := DetermineNodeIP(Worker)
-		masterIP = nodeIP
-		loaderIP = nodeIP
-		workerIPs = []string{nodeIP}
+		fallthrough
 	case IsSingleNode():
 		nodeIP := DetermineNodeIP(SingleNode)
 		masterIP = nodeIP
@@ -201,7 +198,7 @@ func DetermineNodesIPs(multiLoaderConfig *types.MultiLoaderConfiguration) {
 	assignDefaults(&multiLoaderConfig.AutoScalerNode, DeterminePodIP(AutoScalerPod))
 	assignDefaults(&multiLoaderConfig.ActivatorNode, DeterminePodIP(ActivatorPod))
 
-	log.Trace("Node IPs determined", multiLoaderConfig)
+	log.Debug("Node IPs determined", multiLoaderConfig)
 }
 
 /**