update

Signed-off-by: bitliu <[email protected]>

Author: Xunzhuo

.github/workflows/integration-test-k8s.yml

@@ -61,7 +61,7 @@ jobs:
         run: |
           make build-e2e
 
-      - name: Run AI Gateway E2E tests
+      - name: Run Integration E2E tests
         id: e2e-test
         run: |
           set +e  # Don't exit on error, we want to capture the result
@@ -81,6 +81,7 @@ jobs:
           path: |
             test-report.json
             test-report.md
+            semantic-router-logs.txt
           retention-days: 30
 
       - name: Create test summary from report
@@ -90,6 +91,40 @@ jobs:
             echo "=== Reading test report from test-report.md ==="
             cat test-report.md >> $GITHUB_STEP_SUMMARY
 
+            # Add semantic-router logs section if available
+            if [ -f "semantic-router-logs.txt" ]; then
+              cat >> $GITHUB_STEP_SUMMARY << 'EOF'
+
+          ---
+
+          ### 📝 Semantic Router Logs
+
+          <details>
+          <summary>Click to view semantic-router logs</summary>
+
+          ```
+          EOF
+              # Add first 500 lines of logs to summary (to avoid exceeding GitHub limits)
+              head -n 500 semantic-router-logs.txt >> $GITHUB_STEP_SUMMARY
+
+              # Check if there are more lines
+              TOTAL_LINES=$(wc -l < semantic-router-logs.txt)
+              if [ "$TOTAL_LINES" -gt 500 ]; then
+                cat >> $GITHUB_STEP_SUMMARY << EOF
+
+          ... (showing first 500 lines of $TOTAL_LINES total lines)
+
+          📦 Full logs are available in the workflow artifacts: semantic-router-logs.txt
+          EOF
+              fi
+
+              cat >> $GITHUB_STEP_SUMMARY << 'EOF'
+          ```
+
+          </details>
+          EOF
+            fi
+
             # Add additional context
             cat >> $GITHUB_STEP_SUMMARY << 'EOF'
 
@@ -104,10 +139,12 @@ jobs:
           - [E2E Test Framework Documentation](https://github.com/${{ github.repository }}/tree/main/e2e)
           - [AI Gateway Profile](https://github.com/${{ github.repository }}/tree/main/e2e/profiles/ai-gateway)
 
-          ### � Artifacts
+          ### 📦 Artifacts
 
-          - Test reports (JSON and Markdown) are available as workflow artifacts
-          - Reports are retained for 30 days
+          - **test-report.json** - Detailed test results in JSON format
+          - **test-report.md** - Human-readable test report
+          - **semantic-router-logs.txt** - Complete semantic-router pod logs
+          - All artifacts are retained for 30 days
           EOF
           else
             echo "⚠️ Test report file not found!" >> $GITHUB_STEP_SUMMARY

e2e/pkg/framework/runner.go

@@ -3,6 +3,8 @@ package framework
 import (
 	"context"
 	"fmt"
+	"io"
+	"os"
 	"strings"
 	"sync"
 	"time"
@@ -163,6 +165,12 @@ func (r *Runner) Run(ctx context.Context) error {
 		}
 	}
 
+	// Step 7: Collect semantic-router logs (always, regardless of test result)
+	r.log("📝 Collecting semantic-router logs...")
+	if err := r.collectSemanticRouterLogs(ctx, kubeClient); err != nil {
+		r.log("Warning: failed to collect semantic-router logs: %v", err)
+	}
+
 	if hasFailures {
 		exitCode = 1
 		r.log("❌ Some tests failed, printing all pods status for debugging...")
@@ -387,6 +395,79 @@ func (r *Runner) printAllPodsDebugInfo(ctx context.Context, client *kubernetes.C
 	fmt.Printf("\n")
 }
 
+// collectSemanticRouterLogs collects logs from semantic-router pods and saves to file
+func (r *Runner) collectSemanticRouterLogs(ctx context.Context, client *kubernetes.Clientset) error {
+	// Find semantic-router pods
+	pods, err := client.CoreV1().Pods("vllm-semantic-router-system").List(ctx, metav1.ListOptions{})
+	if err != nil {
+		return fmt.Errorf("failed to list semantic-router pods: %w", err)
+	}
+
+	if len(pods.Items) == 0 {
+		r.log("Warning: no semantic-router pods found")
+		return nil
+	}
+
+	// Collect logs from all semantic-router pods
+	var allLogs strings.Builder
+	allLogs.WriteString("========================================\n")
+	allLogs.WriteString("Semantic Router Logs\n")
+	allLogs.WriteString("========================================\n\n")
+
+	for _, pod := range pods.Items {
+		allLogs.WriteString(fmt.Sprintf("=== Pod: %s (Namespace: %s) ===\n", pod.Name, pod.Namespace))
+		allLogs.WriteString(fmt.Sprintf("Status: %s\n", pod.Status.Phase))
+		allLogs.WriteString(fmt.Sprintf("Node: %s\n", pod.Spec.NodeName))
+		if pod.Status.StartTime != nil {
+			allLogs.WriteString(fmt.Sprintf("Started: %s\n", pod.Status.StartTime.Format(time.RFC3339)))
+		}
+		allLogs.WriteString("\n")
+
+		// Collect logs from all containers in the pod
+		for _, container := range pod.Spec.Containers {
+			allLogs.WriteString(fmt.Sprintf("--- Container: %s ---\n", container.Name))
+
+			logOptions := &corev1.PodLogOptions{
+				Container: container.Name,
+			}
+
+			req := client.CoreV1().Pods(pod.Namespace).GetLogs(pod.Name, logOptions)
+			logs, err := req.Stream(ctx)
+			if err != nil {
+				allLogs.WriteString(fmt.Sprintf("Error getting logs: %v\n", err))
+				continue
+			}
+
+			logBytes, err := io.ReadAll(logs)
+			logs.Close()
+			if err != nil {
+				allLogs.WriteString(fmt.Sprintf("Error reading logs: %v\n", err))
+				continue
+			}
+
+			if len(logBytes) == 0 {
+				allLogs.WriteString("(no logs available)\n")
+			} else {
+				allLogs.Write(logBytes)
+				allLogs.WriteString("\n")
+			}
+
+			allLogs.WriteString("\n")
+		}
+
+		allLogs.WriteString("\n")
+	}
+
+	// Write logs to file
+	logFilename := "semantic-router-logs.txt"
+	if err := os.WriteFile(logFilename, []byte(allLogs.String()), 0644); err != nil {
+		return fmt.Errorf("failed to write log file: %w", err)
+	}
+
+	r.log("✅ Semantic router logs saved to: %s", logFilename)
+	return nil
+}
+
 func getPodReadyStatus(pod corev1.Pod) string {
 	readyCount := 0
 	totalCount := len(pod.Status.ContainerStatuses)