Browse Source

Fix(metrics): Update indexer typing and schema (#65921)

Bump kafka version and fix typing
John 1 year ago
parent
commit
afdf0eaa7d

+ 1 - 1
requirements-base.txt

@@ -62,7 +62,7 @@ rfc3339-validator>=0.1.2
 rfc3986-validator>=0.1.1
 rfc3986-validator>=0.1.1
 # [end] jsonschema format validators
 # [end] jsonschema format validators
 sentry-arroyo>=2.16.0
 sentry-arroyo>=2.16.0
-sentry-kafka-schemas>=0.1.56
+sentry-kafka-schemas>=0.1.58
 sentry-ophio==0.1.5
 sentry-ophio==0.1.5
 sentry-redis-tools>=0.1.7
 sentry-redis-tools>=0.1.7
 sentry-relay>=0.8.45
 sentry-relay>=0.8.45

+ 1 - 1
requirements-dev-frozen.txt

@@ -177,7 +177,7 @@ sentry-cli==2.16.0
 sentry-devenv==1.2.3
 sentry-devenv==1.2.3
 sentry-forked-django-stubs==4.2.7.post3
 sentry-forked-django-stubs==4.2.7.post3
 sentry-forked-djangorestframework-stubs==3.14.5.post1
 sentry-forked-djangorestframework-stubs==3.14.5.post1
-sentry-kafka-schemas==0.1.56
+sentry-kafka-schemas==0.1.58
 sentry-ophio==0.1.5
 sentry-ophio==0.1.5
 sentry-redis-tools==0.1.7
 sentry-redis-tools==0.1.7
 sentry-relay==0.8.45
 sentry-relay==0.8.45

+ 1 - 1
requirements-frozen.txt

@@ -119,7 +119,7 @@ rpds-py==0.15.2
 rsa==4.8
 rsa==4.8
 s3transfer==0.10.0
 s3transfer==0.10.0
 sentry-arroyo==2.16.0
 sentry-arroyo==2.16.0
-sentry-kafka-schemas==0.1.56
+sentry-kafka-schemas==0.1.58
 sentry-ophio==0.1.5
 sentry-ophio==0.1.5
 sentry-redis-tools==0.1.7
 sentry-redis-tools==0.1.7
 sentry-relay==0.8.45
 sentry-relay==0.8.45

+ 1 - 3
src/sentry/sentry_metrics/consumers/indexer/batch.py

@@ -484,9 +484,7 @@ class IndexerBatch:
                         "timestamp": old_payload_value["timestamp"],
                         "timestamp": old_payload_value["timestamp"],
                         "project_id": old_payload_value["project_id"],
                         "project_id": old_payload_value["project_id"],
                         "type": old_payload_value["type"],
                         "type": old_payload_value["type"],
-                        # XXX: The payload in ingest-metrics is "any"-typed,
-                        # but the payload in generic-metrics is string-typed
-                        "value": cast(Any, old_payload_value["value"]),
+                        "value": old_payload_value["value"],
                         "sentry_received_timestamp": sentry_received_timestamp,
                         "sentry_received_timestamp": sentry_received_timestamp,
                     }
                     }
                     if aggregation_option := get_aggregation_option(old_payload_value["name"]):
                     if aggregation_option := get_aggregation_option(old_payload_value["name"]):