fixup! fixup! MON-3500: Enable sending exemplars over RW in UWM

Author: rexagod

test/e2e/config_test.go

@@ -619,6 +619,7 @@ func TestUserWorkloadMonitorPrometheusK8Config(t *testing.T) {
     datacenter: eu-west
   remoteWrite:
   - url: "https://test.remotewrite.com/api/write"
+    sendExemplars: true
   volumeClaimTemplate:
     spec:
       resources:
@@ -687,6 +688,10 @@ func TestUserWorkloadMonitorPrometheusK8Config(t *testing.T) {
 			name:      "assert query log file value is set and correct",
 			assertion: assertQueryLogValueEquals(f.UserWorkloadMonitoringNs, crName, "/tmp/test.log"),
 		},
+		{
+			name:      "assert exemplars are enabled",
+			assertion: assertExemplarsEnabled(f.UserWorkloadMonitoringNs),
+		},
 	} {
 		t.Run(tc.name, tc.assertion)
 	}
@@ -1079,3 +1084,24 @@ func assertQueryLogValueEquals(namespace, crName, value string) func(t *testing.
 		}
 	}
 }
+
+func assertExemplarsEnabled(namespace string) func(t *testing.T) {
+	return func(t *testing.T) {
+		err := framework.Poll(time.Second, time.Minute*5, func() error {
+			prom, err := f.MonitoringClient.Prometheuses(namespace).Get(context.Background(), "user-workload", metav1.GetOptions{})
+			if err != nil {
+				t.Fatal("failed to get required prometheus cr", err)
+			}
+			exemplarStorageFeatureFlag := "exemplar-storage"
+			for _, enabledFeature := range prom.Spec.EnableFeatures {
+				if enabledFeature == "exemplar-storage" {
+					return nil
+				}
+			}
+			return fmt.Errorf("expected %s feature to be enabled", exemplarStorageFeatureFlag)
+		})
+		if err != nil {
+			t.Fatal(err)
+		}
+	}
+}