fix obsreport

codeboten · codeboten · commit 75e7afa53add · 2025-07-04T09:43:48.000-07:00
Signed-off-by: alex boten &lt;223565+codeboten@users.noreply.github.com&gt;
diff --git a/processor/processorhelper/obsreport.go b/processor/processorhelper/obsreport.go
@@ -8,7 +8,9 @@ import (
 
 	"go.opentelemetry.io/collector/pipeline"
 	"go.opentelemetry.io/collector/processor"
+	"go.opentelemetry.io/collector/processor/internal"
 	"go.opentelemetry.io/collector/processor/processorhelper/internal/metadata"
+	"go.opentelemetry.io/otel/attribute"
 )
 
 const signalKey = "otel.signal"
@@ -18,7 +20,10 @@ type obsReport struct {
 }
 
 func newObsReport(set processor.Settings, signal pipeline.Signal) (*obsReport, error) {
-	telemetryBuilder, err := metadata.NewTelemetryBuilder(set.TelemetrySettings)
+	telemetryBuilder, err := metadata.NewTelemetryBuilder(set.TelemetrySettings, metadata.WithAttributeSet(attribute.NewSet(
+		attribute.String(internal.ProcessorKey, set.ID.String()),
+		attribute.String(signalKey, signal.String()),
+	)))
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,9 @@ import (`
`8`	`8`
`9`	`9`	`"go.opentelemetry.io/collector/pipeline"`
`10`	`10`	`"go.opentelemetry.io/collector/processor"`
	`11`	`+ "go.opentelemetry.io/collector/processor/internal"`
`11`	`12`	`"go.opentelemetry.io/collector/processor/processorhelper/internal/metadata"`
	`13`	`+ "go.opentelemetry.io/otel/attribute"`
`12`	`14`	`)`
`13`	`15`
`14`	`16`	`const signalKey = "otel.signal"`
`@@ -18,7 +20,10 @@ type obsReport struct {`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`func newObsReport(set processor.Settings, signal pipeline.Signal) (*obsReport, error) {`
`21`		`- telemetryBuilder, err := metadata.NewTelemetryBuilder(set.TelemetrySettings)`
	`23`	`+ telemetryBuilder, err := metadata.NewTelemetryBuilder(set.TelemetrySettings, metadata.WithAttributeSet(attribute.NewSet(`
	`24`	`+ attribute.String(internal.ProcessorKey, set.ID.String()),`
	`25`	`+ attribute.String(signalKey, signal.String()),`
	`26`	`+ )))`
`22`	`27`	`if err != nil {`
`23`	`28`	`return nil, err`
`24`	`29`	`}`