Skip Fleet tests until #6331 is resolved

test/e2e/agent/config_test.go

@@ -124,6 +124,9 @@ func TestMultipleOutputConfig(t *testing.T) {
 }
 
 func TestFleetMode(t *testing.T) {
+
+	test.SkipUntilResolution(t, 6331)
+
 	v := version.MustParse(test.Ctx().ElasticStackVersion)
 	// installation of policies and integrations through Kibana file based configuration was broken between those versions:
 	if v.LT(version.MinFor(8, 1, 0)) && v.GTE(version.MinFor(8, 0, 0)) {

test/e2e/agent/recipes_test.go

@@ -88,8 +88,8 @@ func TestMultiOutputRecipe(t *testing.T) {
 }
 
 func TestFleetKubernetesIntegrationRecipe(t *testing.T) {
-	// This test is disabled until we understand why it is failing
-	t.Skip("TestFleetKubernetesIntegrationRecipe is disabled, see https://github.com/elastic/cloud-on-k8s/issues/6331")
+
+	test.SkipUntilResolution(t, 6331)
 
 	customize := func(builder agent.Builder) agent.Builder {
 		if !builder.Agent.Spec.FleetServerEnabled {
@@ -133,6 +133,9 @@ func TestFleetKubernetesIntegrationRecipe(t *testing.T) {
 }
 
 func TestFleetCustomLogsIntegrationRecipe(t *testing.T) {
+
+	test.SkipUntilResolution(t, 6331)
+
 	notLoggingPod := beat.NewPodBuilder("test")
 	loggingPod := beat.NewPodBuilder("test")
 	loggingPod.Pod.Namespace = "default"
@@ -159,6 +162,9 @@ func TestFleetCustomLogsIntegrationRecipe(t *testing.T) {
 }
 
 func TestFleetAPMIntegrationRecipe(t *testing.T) {
+
+	test.SkipUntilResolution(t, 6331)
+
 	customize := func(builder agent.Builder) agent.Builder {
 		if !builder.Agent.Spec.FleetServerEnabled {
 			return builder

test/e2e/agent/upgrade_test.go

@@ -16,6 +16,9 @@ import (
 )
 
 func TestAgentVersionUpgradeToLatest8x(t *testing.T) {
+
+	test.SkipUntilResolution(t, 6331)
+
 	srcVersion, dstVersion := test.GetUpgradePathTo8x(test.Ctx().ElasticStackVersion)
 
 	test.SkipInvalidUpgrade(t, srcVersion, dstVersion)

test/e2e/test/utils.go

@@ -177,3 +177,7 @@ func IsGKE(v version.Version) bool {
 	// cloud providers append the name of the k8s platform in the version prefix (e.g.: 1.21.6-gke.1503)
 	return strings.Contains(v.String(), "gke")
 }
+
+func SkipUntilResolution(t *testing.T, knownIssueNumber int) {
+	t.Skip(fmt.Sprintf("Skip until we understand why it is failing, see https://github.com/elastic/cloud-on-k8s/issues/%d", knownIssueNumber))
+}