test

project-kessel · Feb 25, 2025 · 248f413 · 248f413
1 parent 499732f
commit 248f413
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/test/e2e/inventory_http_test.go b/test/e2e/inventory_http_test.go
@@ -450,12 +450,12 @@ func TestInventoryAPIHTTP_K8SPolicy_is_propagated_to_K8sClusterLifecycle(t *test
 		K8SPolicy: &resources.K8SPolicy{
 			Metadata: &resources.Metadata{
 				ResourceType: "k8s_policy",
-				WorkspaceId:  "workspace8",
+				WorkspaceId:  "workspace81",
 				OrgId:        "",
 			},
 			ResourceData: &resources.K8SPolicyDetail{
 				Disabled: true,
-				Severity: resources.K8SPolicyDetail_HIGH,
+				Severity: resources.K8SPolicyDetail_LOW,
 			},
 			ReporterData: &resources.ReporterData{
 				ReporterInstanceId: "user@example.com",

diff --git a/test/e2e/kafkaconsumer_test.go b/test/e2e/kafkaconsumer_test.go
@@ -126,7 +126,7 @@ func Test_ACMKafkaConsumer(t *testing.T) {
 		t.Fatalf("Failed to create Kafka admin client: %v", err)
 	}
 	defer adminClient.Close()
-
+	time.Sleep(10 * time.Second)
 	if err := ensureTopicExists(adminClient, topic); err != nil {
 		t.Fatalf("Failed to ensure topic exists: %v", err)
 	}