Skip to content

Commit 41034e3

Browse files
john-z-yangandrewshie-sentry
authored andcommitted
tele(taskbroker): fix compression metrics (#91818)
1 parent 9712b9a commit 41034e3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/sentry/profiles/consumers/process/factory.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,13 @@ def process_message(message: Message[KafkaPayload]) -> None:
2020
if sampled or options.get("profiling.profile_metrics.unsampled_profiles.enabled"):
2121
b64encoded = b64encode(message.payload.value).decode("utf-8")
2222
process_profile_task.delay(payload=b64encoded, sampled=sampled)
23-
metrics.distribution("profiling.profile_metrics.uncompressed_bytes", len(b64encoded))
2423

2524
if random.random() < options.get("taskworker.try_compress.profile_metrics"):
2625
import time
2726
import zlib
2827

28+
metrics.distribution("profiling.profile_metrics.uncompressed_bytes", len(b64encoded))
29+
2930
start_time = time.perf_counter()
3031
metrics.distribution(
3132
"profiling.profile_metrics.compressed_bytes",

0 commit comments

Comments
 (0)