diff --git a/internal/testbed/integration/redaction/e2e_test.go b/internal/testbed/integration/redaction/e2e_test.go index a290873a..632fae7a 100644 --- a/internal/testbed/integration/redaction/e2e_test.go +++ b/internal/testbed/integration/redaction/e2e_test.go @@ -59,4 +59,15 @@ func TestE2E_ClusterRBAC(t *testing.T) { OtlpEndpoint: fmt.Sprintf("otelcol-%s.%s:4317", testID, testNs), DataTypes: []string{"traces"}, } + telemetryGenObjs, telemetryGenObjInfos := k8stest.CreateTelemetryGenObjects(t, k8sClient, createTeleOpts) + defer func() { + for _, obj := range append(collectorObjs, telemetryGenObjs...) { + require.NoErrorf(t, k8stest.DeleteObject(k8sClient, obj), "failed to delete object %s", obj.GetName()) + } + }() + + for _, info := range telemetryGenObjInfos { + k8stest.WaitForTelemetryGenToStart(t, k8sClient, info.Namespace, info.PodLabelSelectors, info.Workload, info.DataType) + } + }