Revert "ref: bump sentry-arroyo to 2.14.16" (#59074)

Reverts getsentry/sentry#59047

requirements-base.txt

@@ -59,7 +59,7 @@ requests>=2.25.1
 rfc3339-validator>=0.1.2
 rfc3986-validator>=0.1.1
 # [end] jsonschema format validators
-sentry-arroyo>=2.14.16
+sentry-arroyo>=2.14.12
 sentry-kafka-schemas>=0.1.32
 sentry-redis-tools>=0.1.7
 sentry-relay>=0.8.32

requirements-dev-frozen.txt

@@ -169,7 +169,7 @@ rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.6.1
 selenium==4.3.0
-sentry-arroyo==2.14.16
+sentry-arroyo==2.14.12
 sentry-cli==2.16.0
 sentry-kafka-schemas==0.1.32
 sentry-redis-tools==0.1.7

requirements-frozen.txt

@@ -111,7 +111,7 @@ rfc3339-validator==0.1.2
 rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.6.1
-sentry-arroyo==2.14.16
+sentry-arroyo==2.14.12
 sentry-kafka-schemas==0.1.32
 sentry-redis-tools==0.1.7
 sentry-relay==0.8.32

src/sentry/consumers/synchronized.py

@@ -164,7 +164,7 @@ class SynchronizedConsumer(Consumer[TStrategyPayload]):
             if commit.orig_message_ts is not None:
                 metrics.timing(
                     "commit_log_msg_latency",
-                    (now - commit.orig_message_ts) * 1000,
+                    (now - datetime.timestamp(commit.orig_message_ts)) * 1000,
                     tags={
                         "partition": str(commit.partition.index),
                         "group": commit.group,

tests/sentry/consumers/test_synchronized.py

@@ -112,8 +112,7 @@ def test_synchronized_consumer() -> None:
                         "leader-a",
                         Partition(topic, 0),
                         messages[0].next_offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     ),
                 ),
             ).result(),
@@ -135,8 +134,7 @@ def test_synchronized_consumer() -> None:
                         "leader-b",
                         Partition(topic, 0),
                         messages[0].next_offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     )
                 ),
             ).result(),
@@ -166,13 +164,7 @@ def test_synchronized_consumer() -> None:
         producer.produce(
             commit_log_topic,
             commit_codec.encode(
-                Commit(
-                    "leader-a",
-                    Partition(topic, 0),
-                    messages[3].offset,
-                    datetime.now().timestamp(),
-                    None,
-                )
+                Commit("leader-a", Partition(topic, 0), messages[3].offset, datetime.now())
             ),
         ).result()
 
@@ -185,8 +177,7 @@ def test_synchronized_consumer() -> None:
                         "leader-b",
                         Partition(topic, 0),
                         messages[5].offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     )
                 ),
             ).result(),
@@ -227,8 +218,7 @@ def test_synchronized_consumer() -> None:
                         "leader-a",
                         Partition(topic, 0),
                         messages[5].offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     )
                 ),
             ).result(),
@@ -290,8 +280,7 @@ def test_synchronized_consumer_pause_resume() -> None:
                         "leader",
                         Partition(topic, 0),
                         messages[0].next_offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     )
                 ),
             ).result(),
@@ -367,8 +356,7 @@ def test_synchronized_consumer_handles_end_of_partition() -> None:
                         "leader",
                         Partition(topic, 0),
                         messages[0].next_offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     ),
                 ),
             ).result(),
@@ -387,8 +375,7 @@ def test_synchronized_consumer_handles_end_of_partition() -> None:
                         "leader",
                         Partition(topic, 0),
                         messages[1].next_offset,
-                        datetime.now().timestamp(),
-                        None,
+                        datetime.now(),
                     ),
                 ),
             ).result(),