chore: improve OTTL Spec condition message (kyma-project#2681)

TeodorSAP · NHingerl · skhalash · web-flow · commit 6092786bb0ac · 2025-12-01T10:29:41.000Z
Co-authored-by: Nina Hingerl &lt;76950046+NHingerl@users.noreply.github.com&gt;
Co-authored-by: Stanislav Khalash &lt;stanislav.khalash@sap.com&gt;
diff --git a/docs/user/resources/01-telemetry.md b/docs/user/resources/01-telemetry.md
diff --git a/docs/user/resources/02-logpipeline.md b/docs/user/resources/02-logpipeline.md
diff --git a/docs/user/resources/04-tracepipeline.md b/docs/user/resources/04-tracepipeline.md
diff --git a/docs/user/resources/05-metricpipeline.md b/docs/user/resources/05-metricpipeline.md
diff --git a/docs/user/troubleshooting.md b/docs/user/troubleshooting.md
@@ -2,6 +2,8 @@
 
 Troubleshoot problems related to the Telemetry module and its pipelines.
 
+If you can't find a solution, don't hesitate to create a [GitHub issue](https://github.com/kyma-project/telemetry-manager/issues/new/choose).
+
 ## No Data Arrive at the Backend
 
 ### Symptom
@@ -146,7 +148,6 @@ There's a configuration or network issue between the metric agent and your appli
             telemetry.kyma-project.io/metric-scrape: "true"
     policyTypes:
     - Ingress
-
   ```
 
 ## LogPipeline: Log Buffer Filling Up
@@ -185,36 +186,29 @@ This usually happens for one of the following reasons:
 2. Test your regex separately. Simplify complex conditions to a single comparison and re-apply.
 3. To test your rules, temporarily remove all but one rule to confirm it works as expected. Then, add your other rules incrementally and isolate the rule that is causing the issue.
 
-## Generic EOF Error Message When Using OTTL Transform or Filter
+## OTTL Spec Invalid with Unspecific Error Message
 
 ### Symptom
 
-- The pipeline configuration fails with vague error messages mentioning "unexpected token `<EOF>`" or EOF (End of File) parsing errors.
 - In the pipeline status, you see the condition `ConfigurationGenerated` with status `False` and reason `OTTLSpecInvalid`.
+- The pipeline configuration fails with unclear error messages, for example, mentioning "unexpected token `<EOF>`" or EOF (End of File) parsing errors, such as the following example:
+
+```yaml
+'Invalid FilterSpec: condition has invalid syntax: 1:64: unexpected token
+      "<EOF>" (expected <opcomparison> Value)'
+```
 
 ### Cause
 
-This error occurs when there is a syntax error in the used OTTL functions in your transformation or filter rules. If syntax validation cannot diagnose the error precisely, you get a generic EOF error instead of a specific error message.
+If you get a generic EOF error instead of a specific error message, there's usually a syntax error in your OTTL transformation or filter rules. It occurs when the parser cannot diagnose the error precisely.
 
-The following example uses the incorrect function name `isMatch` (it should be `IsMatch`):
+The following example uses the incorrect function name `isMatch` (it should be `IsMatch`, because he parser is case-sensitive):
 ```yaml
 # ...
 filter:
     - conditions:
         - 'isMatch(resource.attributes["k8s.namespace.name"], ".*-system")'
 ```
-This mistake produces a generic error message in the `ConfigurationGenerated` status condition of the pipeline, because the parser is case-sensitive and does not recognize the function:
-```yaml
-status:
-  conditions:
-  - lastTransitionTime: "2025-11-11T14:18:19Z"
-    message: 'Invalid FilterSpec: condition has invalid syntax: 1:64: unexpected token
-      "<EOF>" (expected <opcomparison> Value)'
-    observedGeneration: 1
-    reason: OTTLSpecInvalid
-    status: "False"
-    type: ConfigurationGenerated
-```
 
 ### Solution
 
diff --git a/internal/conditions/conditions.go b/internal/conditions/conditions.go
@@ -6,6 +6,7 @@ const (
 	LinkNoDataArriveAtBackend     = "https://kyma-project.io/external-content/telemetry-manager/docs/user/troubleshooting.html#no-data-arrive-at-the-backend"
 	LinkNotAllDataArriveAtBackend = "https://kyma-project.io/external-content/telemetry-manager/docs/user/troubleshooting.html#not-all-data-arrive-at-the-backend"
 	LinkGatewayThrottling         = "https://kyma-project.io/external-content/telemetry-manager/docs/user/troubleshooting.html#gateway-throttling"
+	LinkOTTLSpecInvalid           = "https://kyma-project.io/external-content/telemetry-manager/docs/user/troubleshooting.html#ottl-spec-invalid-with-unspecific-error-message"
 
 	LinkFluentBitNoLogsArriveAtBackend     = "https://kyma-project.io/#/telemetry-manager/user/02-logs?id=no-logs-arrive-at-the-backend"
 	LinkFluentBitNotAllLogsArriveAtBackend = "https://kyma-project.io/#/telemetry-manager/user/02-logs?id=not-all-logs-arrive-at-the-backend"
@@ -83,6 +84,7 @@ var commonMessages = map[string]string{
 	ReasonSelfMonAgentProbingFailed:   "Could not determine the health of the telemetry flow because the self monitor probing of agent failed",
 	ReasonTLSConfigurationInvalid:     "TLS configuration invalid: %s",
 	ReasonValidationFailed:            "Pipeline validation failed due to an error from the Kubernetes API server",
+	ReasonOTTLSpecInvalid:             "OTTL specification is invalid, %s. Fix the syntax error indicated by the message or see troubleshooting: " + LinkOTTLSpecInvalid,
 }
 
 var commonLogPipelineMessages = map[string]string{
diff --git a/internal/reconciler/logpipeline/otel/reconciler_test.go b/internal/reconciler/logpipeline/otel/reconciler_test.go
@@ -308,7 +308,7 @@ func TestOTTLSpecValidation(t *testing.T) {
 				))),
 			condStatus:  metav1.ConditionFalse,
 			condReason:  conditions.ReasonOTTLSpecInvalid,
-			condMessage: "Invalid TransformSpec: error while parsing statements",
+			condMessage: "OTTL specification is invalid, invalid TransformSpec: error while parsing statements. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 		{
 			name: "invalid filter spec",
@@ -320,7 +320,7 @@ func TestOTTLSpecValidation(t *testing.T) {
 				))),
 			condStatus:  metav1.ConditionFalse,
 			condReason:  conditions.ReasonOTTLSpecInvalid,
-			condMessage: "Invalid FilterSpec: error while parsing conditions",
+			condMessage: "OTTL specification is invalid, invalid FilterSpec: error while parsing conditions. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 	}
 
diff --git a/internal/reconciler/logpipeline/otel/status.go b/internal/reconciler/logpipeline/otel/status.go
@@ -179,7 +179,9 @@ func (r *Reconciler) evaluateConfigGeneratedCondition(ctx context.Context, pipel
 	}
 
 	if ottl.IsInvalidOTTLSpecError(err) {
-		return metav1.ConditionFalse, conditions.ReasonOTTLSpecInvalid, conditions.ConvertErrToMsg(err)
+		return metav1.ConditionFalse,
+			conditions.ReasonOTTLSpecInvalid,
+			fmt.Sprintf(conditions.MessageForOtelLogPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
 	}
 
 	var APIRequestFailed *errortypes.APIRequestFailedError
diff --git a/internal/reconciler/metricpipeline/reconciler_test.go b/internal/reconciler/metricpipeline/reconciler_test.go
@@ -598,14 +598,14 @@ func TestOTTLSpecValidation(t *testing.T) {
 			validatorOption: WithTransformSpecValidator(stubs.NewTransformSpecValidator(
 				&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid TransformSpec: error while parsing statements")},
 			)),
-			expectedMessage: "Invalid TransformSpec: error while parsing statements",
+			expectedMessage: "OTTL specification is invalid, invalid TransformSpec: error while parsing statements. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 		{
 			name: "invalid filter spec",
 			validatorOption: WithFilterSpecValidator(stubs.NewFilterSpecValidator(
-				&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid FilterSpec: error while parsing statements")},
+				&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid FilterSpec: error while parsing conditions")},
 			)),
-			expectedMessage: "Invalid FilterSpec: error while parsing statements",
+			expectedMessage: "OTTL specification is invalid, invalid FilterSpec: error while parsing conditions. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 	}
 
diff --git a/internal/reconciler/metricpipeline/status.go b/internal/reconciler/metricpipeline/status.go
@@ -114,7 +114,9 @@ func (r *Reconciler) evaluateConfigGeneratedCondition(ctx context.Context, pipel
 	}
 
 	if ottl.IsInvalidOTTLSpecError(err) {
-		return metav1.ConditionFalse, conditions.ReasonOTTLSpecInvalid, conditions.ConvertErrToMsg(err)
+		return metav1.ConditionFalse,
+			conditions.ReasonOTTLSpecInvalid,
+			fmt.Sprintf(conditions.MessageForMetricPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
 	}
 
 	var APIRequestFailed *errortypes.APIRequestFailedError
diff --git a/internal/reconciler/tracepipeline/reconciler_test.go b/internal/reconciler/tracepipeline/reconciler_test.go
@@ -467,16 +467,16 @@ func TestOTTLSpecValidation(t *testing.T) {
 					&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid TransformSpec: error while parsing statements")},
 				))
 			},
-			expectedErrorMsg: "Invalid TransformSpec: error while parsing statements",
+			expectedErrorMsg: "OTTL specification is invalid, invalid TransformSpec: error while parsing statements. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 		{
 			name: "invalid filter spec",
 			validatorOption: func() ValidatorOption {
 				return WithFilterSpecValidator(stubs.NewFilterSpecValidator(
-					&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid FilterSpec: error while parsing statements")},
+					&ottl.InvalidOTTLSpecError{Err: fmt.Errorf("invalid FilterSpec: error while parsing conditions")},
 				))
 			},
-			expectedErrorMsg: "Invalid FilterSpec: error while parsing statements",
+			expectedErrorMsg: "OTTL specification is invalid, invalid FilterSpec: error while parsing conditions. Fix the syntax error indicated by the message or see troubleshooting: " + conditions.LinkOTTLSpecInvalid,
 		},
 	}
 
diff --git a/internal/reconciler/tracepipeline/status.go b/internal/reconciler/tracepipeline/status.go
@@ -94,7 +94,9 @@ func (r *Reconciler) evaluateConfigGeneratedCondition(ctx context.Context, pipel
 	}
 
 	if ottl.IsInvalidOTTLSpecError(err) {
-		return metav1.ConditionFalse, conditions.ReasonOTTLSpecInvalid, conditions.ConvertErrToMsg(err)
+		return metav1.ConditionFalse,
+			conditions.ReasonOTTLSpecInvalid,
+			fmt.Sprintf(conditions.MessageForTracePipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
 	}
 
 	var APIRequestFailed *errortypes.APIRequestFailedError
diff --git a/webhook/logpipeline/v1alpha1/validator.go b/webhook/logpipeline/v1alpha1/validator.go
@@ -9,6 +9,8 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/webhook/admission"
 
 	telemetryv1alpha1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1alpha1"
+	telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
+	"github.com/kyma-project/telemetry-manager/internal/conditions"
 	logpipelineutils "github.com/kyma-project/telemetry-manager/internal/utils/logpipeline"
 	"github.com/kyma-project/telemetry-manager/internal/validators/ottl"
 	webhookutils "github.com/kyma-project/telemetry-manager/webhook/utils"
@@ -30,7 +32,7 @@ func (v *LogPipelineValidator) ValidateCreate(_ context.Context, obj runtime.Obj
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(logPipeline.Spec.Filters, logPipeline.Spec.Transforms)
 
-	if err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, filterSpec, transformSpec); err != nil {
+	if err := validateFilterTransform(filterSpec, transformSpec); err != nil {
 		return nil, err
 	}
 
@@ -56,7 +58,7 @@ func (v *LogPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(logPipeline.Spec.Filters, logPipeline.Spec.Transforms)
 
-	if err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, filterSpec, transformSpec); err != nil {
+	if err := validateFilterTransform(filterSpec, transformSpec); err != nil {
 		return nil, err
 	}
 
@@ -74,3 +76,12 @@ func (v *LogPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj
 func (v *LogPipelineValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error) {
 	return nil, nil
 }
+
+func validateFilterTransform(filterSpec []telemetryv1beta1.FilterSpec, transformSpec []telemetryv1beta1.TransformSpec) error {
+	err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, filterSpec, transformSpec)
+	if err != nil {
+		return fmt.Errorf(conditions.MessageForOtelLogPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
+	}
+
+	return nil
+}
diff --git a/webhook/logpipeline/v1beta1/validator.go b/webhook/logpipeline/v1beta1/validator.go
@@ -9,6 +9,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/webhook/admission"
 
 	telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
+	"github.com/kyma-project/telemetry-manager/internal/conditions"
 	"github.com/kyma-project/telemetry-manager/internal/validators/ottl"
 	webhookutils "github.com/kyma-project/telemetry-manager/webhook/utils"
 )
@@ -27,7 +28,7 @@ func (v *LogPipelineValidator) ValidateCreate(_ context.Context, obj runtime.Obj
 		return nil, fmt.Errorf("expected a LogPipeline but got %T", obj)
 	}
 
-	if err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, logPipeline.Spec.Filters, logPipeline.Spec.Transforms); err != nil {
+	if err := validateFilterTransform(logPipeline.Spec.Filters, logPipeline.Spec.Transforms); err != nil {
 		return nil, err
 	}
 
@@ -51,7 +52,7 @@ func (v *LogPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj
 		return nil, fmt.Errorf("expected a LogPipeline but got %T", newObj)
 	}
 
-	if err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, logPipeline.Spec.Filters, logPipeline.Spec.Transforms); err != nil {
+	if err := validateFilterTransform(logPipeline.Spec.Filters, logPipeline.Spec.Transforms); err != nil {
 		return nil, err
 	}
 
@@ -80,3 +81,12 @@ func containsCustomPlugin(lp *telemetryv1beta1.LogPipeline) bool {
 
 	return lp.Spec.Output.Custom != ""
 }
+
+func validateFilterTransform(filterSpec []telemetryv1beta1.FilterSpec, transformSpec []telemetryv1beta1.TransformSpec) error {
+	err := webhookutils.ValidateFilterTransform(ottl.SignalTypeLog, filterSpec, transformSpec)
+	if err != nil {
+		return fmt.Errorf(conditions.MessageForOtelLogPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
+	}
+
+	return nil
+}
diff --git a/webhook/metricpipeline/v1alpha1/validator.go b/webhook/metricpipeline/v1alpha1/validator.go
@@ -9,6 +9,8 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/webhook/admission"
 
 	telemetryv1alpha1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1alpha1"
+	telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
+	"github.com/kyma-project/telemetry-manager/internal/conditions"
 	"github.com/kyma-project/telemetry-manager/internal/validators/ottl"
 	webhookutils "github.com/kyma-project/telemetry-manager/webhook/utils"
 )
@@ -27,7 +29,7 @@ func (v *MetricPipelineValidator) ValidateCreate(_ context.Context, obj runtime.
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, filterSpec, transformSpec)
+	return nil, validateFilterTransform(filterSpec, transformSpec)
 }
 
 func (v *MetricPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error) {
@@ -39,9 +41,18 @@ func (v *MetricPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newO
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, filterSpec, transformSpec)
+	return nil, validateFilterTransform(filterSpec, transformSpec)
 }
 
 func (v *MetricPipelineValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error) {
 	return nil, nil
 }
+
+func validateFilterTransform(filterSpec []telemetryv1beta1.FilterSpec, transformSpec []telemetryv1beta1.TransformSpec) error {
+	err := webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, filterSpec, transformSpec)
+	if err != nil {
+		return fmt.Errorf(conditions.MessageForMetricPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
+	}
+
+	return nil
+}
diff --git a/webhook/metricpipeline/v1beta1/validator.go b/webhook/metricpipeline/v1beta1/validator.go
@@ -9,6 +9,7 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/webhook/admission"
 
 	telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
+	"github.com/kyma-project/telemetry-manager/internal/conditions"
 	"github.com/kyma-project/telemetry-manager/internal/validators/ottl"
 	webhookutils "github.com/kyma-project/telemetry-manager/webhook/utils"
 )
@@ -25,7 +26,7 @@ func (v *MetricPipelineValidator) ValidateCreate(_ context.Context, obj runtime.
 		return nil, fmt.Errorf("expected a MetricPipeline but got %T", obj)
 	}
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
+	return nil, validateFilterTransform(metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
 }
 
 func (v *MetricPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error) {
@@ -35,9 +36,18 @@ func (v *MetricPipelineValidator) ValidateUpdate(_ context.Context, oldObj, newO
 		return nil, fmt.Errorf("expected a MetricPipeline but got %T", newObj)
 	}
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
+	return nil, validateFilterTransform(metricPipeline.Spec.Filters, metricPipeline.Spec.Transforms)
 }
 
 func (v *MetricPipelineValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error) {
 	return nil, nil
 }
+
+func validateFilterTransform(filterSpec []telemetryv1beta1.FilterSpec, transformSpec []telemetryv1beta1.TransformSpec) error {
+	err := webhookutils.ValidateFilterTransform(ottl.SignalTypeMetric, filterSpec, transformSpec)
+	if err != nil {
+		return fmt.Errorf(conditions.MessageForMetricPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
+	}
+
+	return nil
+}
diff --git a/webhook/tracepipeline/v1alpha1/validator.go b/webhook/tracepipeline/v1alpha1/validator.go
@@ -9,6 +9,8 @@ import (
 	"sigs.k8s.io/controller-runtime/pkg/webhook/admission"
 
 	telemetryv1alpha1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1alpha1"
+	telemetryv1beta1 "github.com/kyma-project/telemetry-manager/apis/telemetry/v1beta1"
+	"github.com/kyma-project/telemetry-manager/internal/conditions"
 	"github.com/kyma-project/telemetry-manager/internal/validators/ottl"
 	webhookutils "github.com/kyma-project/telemetry-manager/webhook/utils"
 )
@@ -27,7 +29,7 @@ func (v *TracePipelineValidator) ValidateCreate(_ context.Context, obj runtime.O
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(tracePipeline.Spec.Filters, tracePipeline.Spec.Transforms)
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeTrace, filterSpec, transformSpec)
+	return nil, validateFilterTransform(filterSpec, transformSpec)
 }
 
 func (v *TracePipelineValidator) ValidateUpdate(_ context.Context, oldObj, newObj runtime.Object) (admission.Warnings, error) {
@@ -39,9 +41,18 @@ func (v *TracePipelineValidator) ValidateUpdate(_ context.Context, oldObj, newOb
 
 	filterSpec, transformSpec := webhookutils.ConvertFilterTransformToBeta(tracePipeline.Spec.Filters, tracePipeline.Spec.Transforms)
 
-	return nil, webhookutils.ValidateFilterTransform(ottl.SignalTypeTrace, filterSpec, transformSpec)
+	return nil, validateFilterTransform(filterSpec, transformSpec)
 }
 
 func (v *TracePipelineValidator) ValidateDelete(_ context.Context, obj runtime.Object) (admission.Warnings, error) {
 	return nil, nil
 }
+
+func validateFilterTransform(filterSpec []telemetryv1beta1.FilterSpec, transformSpec []telemetryv1beta1.TransformSpec) error {
+	err := webhookutils.ValidateFilterTransform(ottl.SignalTypeTrace, filterSpec, transformSpec)
+	if err != nil {
+		return fmt.Errorf(conditions.MessageForTracePipeline(conditions.ReasonOTTLSpecInvalid), err.Error())
+	}
+
+	return nil
+}
diff --git a/webhook/tracepipeline/v1beta1/validator.go b/webhook/tracepipeline/v1beta1/validator.go

Original file line number	Diff line number	Diff line change
`@@ -179,7 +179,9 @@ func (r *Reconciler) evaluateConfigGeneratedCondition(ctx context.Context, pipel`
`179`	`179`	`}`
`180`	`180`
`181`	`181`	`if ottl.IsInvalidOTTLSpecError(err) {`
`182`		`- return metav1.ConditionFalse, conditions.ReasonOTTLSpecInvalid, conditions.ConvertErrToMsg(err)`
	`182`	`+ return metav1.ConditionFalse,`
	`183`	`+ conditions.ReasonOTTLSpecInvalid,`
	`184`	`+ fmt.Sprintf(conditions.MessageForOtelLogPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())`
`183`	`185`	`}`
`184`	`186`
`185`	`187`	`var APIRequestFailed *errortypes.APIRequestFailedError`
Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,9 @@ func (r *Reconciler) evaluateConfigGeneratedCondition(ctx context.Context, pipel`
`114`	`114`	`}`
`115`	`115`
`116`	`116`	`if ottl.IsInvalidOTTLSpecError(err) {`
`117`		`- return metav1.ConditionFalse, conditions.ReasonOTTLSpecInvalid, conditions.ConvertErrToMsg(err)`
	`117`	`+ return metav1.ConditionFalse,`
	`118`	`+ conditions.ReasonOTTLSpecInvalid,`
	`119`	`+ fmt.Sprintf(conditions.MessageForMetricPipeline(conditions.ReasonOTTLSpecInvalid), err.Error())`
`118`	`120`	`}`
`119`	`121`
`120`	`122`	`var APIRequestFailed *errortypes.APIRequestFailedError`