ref(profile): utf8 encode compressed values (#92160)

john-z-yang · web-flow · commit 65bd0297d3c9 · 2025-05-23T12:20:34.000-04:00
diff --git a/src/sentry/profiles/consumers/process/factory.py b/src/sentry/profiles/consumers/process/factory.py
@@ -34,7 +34,7 @@ def process_message(message: Message[KafkaPayload]) -> None:
                     message.payload.value,
                     level=options.get("taskworker.try_compress.profile_metrics.level"),
                 )
-            )
+            ).decode("utf-8")
             metrics.distribution(
                 "profiling.profile_metrics.compressed_bytes",
                 len(b64encoded_compressed),

Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ def process_message(message: Message[KafkaPayload]) -> None:`
`34`	`34`	`message.payload.value,`
`35`	`35`	`level=options.get("taskworker.try_compress.profile_metrics.level"),`
`36`	`36`	`)`
`37`		`- )`
	`37`	`+ ).decode("utf-8")`
`38`	`38`	`metrics.distribution(`
`39`	`39`	`"profiling.profile_metrics.compressed_bytes",`
`40`	`40`	`len(b64encoded_compressed),`