ref(profile): remove compression param (#93349)

Author: john-z-yang

src/sentry/profiles/task.py

@@ -92,25 +92,24 @@ def _get_profiles_producer_from_topic(topic: Topic) -> KafkaProducer:
 logger = logging.getLogger(__name__)
 
 
-def decode_payload(encoded: str, compressed_profile: bool) -> dict[str, Any]:
-    if compressed_profile:
-        try:
-            res = msgpack.unpackb(
-                zlib.decompress(b64decode(encoded.encode("utf-8"))), use_list=False
-            )
-            metrics.incr("profiling.profile_metrics.decompress", tags={"status": "ok"})
-            return res
-        except Exception as e:
-            logger.exception("Failed to decompress compressed profile", extra={"error": e})
-            metrics.incr("profiling.profile_metrics.decompress", tags={"status": "err"})
-            raise
-
-    # not compressed
-    return msgpack.unpackb(b64decode(encoded.encode("utf-8")), use_list=False)
+def decode_payload(encoded: str) -> dict[str, Any]:
+    try:
+        res = msgpack.unpackb(zlib.decompress(b64decode(encoded.encode("utf-8"))), use_list=False)
+        metrics.incr("profiling.profile_metrics.decompress", tags={"status": "ok"})
+        return res
+    except Exception as e:
+        logger.exception("Failed to decompress compressed profile", extra={"error": e})
+        metrics.incr("profiling.profile_metrics.decompress", tags={"status": "err"})
+        raise
 
 
 def encode_payload(message: dict[str, Any]) -> str:
-    return b64encode(msgpack.packb(message)).decode("utf-8")
+    return b64encode(
+        zlib.compress(
+            msgpack.packb(message),
+            level=1,
+        )
+    ).decode("utf-8")
 
 
 @instrumented_task(
@@ -137,14 +136,13 @@ def process_profile_task(
     profile: Profile | None = None,
     payload: str | None = None,
     sampled: bool = True,
-    compressed_profile: bool = False,
     **kwargs: Any,
 ) -> None:
     if not sampled and not options.get("profiling.profile_metrics.unsampled_profiles.enabled"):
         return
 
     if payload:
-        message_dict = decode_payload(payload, compressed_profile)
+        message_dict = decode_payload(payload)
 
         profile = json.loads(message_dict["payload"], use_rapid_json=True)