build: Arroyo 2.14.0 (#51662)

requirements-base.txt

@@ -58,7 +58,7 @@ requests>=2.25.1
 rfc3339-validator>=0.1.2
 rfc3986-validator>=0.1.1
 # [end] jsonschema format validators
-sentry-arroyo>=2.13.0
+sentry-arroyo>=2.14.0
 sentry-kafka-schemas>=0.1.12
 sentry-redis-tools>=0.1.5
 sentry-relay>=0.8.25

requirements-dev-frozen.txt

@@ -166,7 +166,7 @@ rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.5.2
 selenium==4.3.0
-sentry-arroyo==2.13.0
+sentry-arroyo==2.14.0
 sentry-cli==2.16.0
 sentry-kafka-schemas==0.1.12
 sentry-redis-tools==0.1.5

requirements-frozen.txt

@@ -115,7 +115,7 @@ rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.5.2
 selenium==4.3.0
-sentry-arroyo==2.13.0
+sentry-arroyo==2.14.0
 sentry-kafka-schemas==0.1.12
 sentry-redis-tools==0.1.5
 sentry-relay==0.8.25

src/sentry/replays/consumers/recording.py

@@ -5,7 +5,7 @@ from typing import Any, Mapping
 
 import sentry_sdk
 from arroyo.backends.kafka.consumer import KafkaPayload
-from arroyo.processing.strategies import RunTaskInThreads, TransformStep
+from arroyo.processing.strategies import RunTask, RunTaskInThreads
 from arroyo.processing.strategies.abstract import ProcessingStrategyFactory
 from arroyo.processing.strategies.commit import CommitOffsets
 from arroyo.types import Commit, Message, Partition
@@ -51,7 +51,7 @@ class ProcessReplayRecordingStrategyFactory(ProcessingStrategyFactory[KafkaPaylo
             next_step=CommitOffsets(commit),
         )
 
-        return TransformStep(
+        return RunTask(
             function=initialize_message_context,
             next_step=step,
         )

src/sentry/sentry_metrics/consumers/last_seen_updater.py

@@ -13,7 +13,6 @@ from arroyo.processing.strategies.commit import CommitOffsets
 from arroyo.processing.strategies.filter import FilterStep
 from arroyo.processing.strategies.reduce import Reduce
 from arroyo.processing.strategies.run_task import RunTask
-from arroyo.processing.strategies.transform import TransformStep
 from arroyo.types import BaseValue, Commit, Message, Partition, Topic
 from django.utils import timezone
 
@@ -147,7 +146,7 @@ class LastSeenUpdaterStrategyFactory(ProcessingStrategyFactory[KafkaPayload]):
             RunTask(do_update, CommitOffsets(commit)),
         )
 
-        transform_step = TransformStep(retrieve_db_read_keys, collect_step)
+        transform_step = RunTask(retrieve_db_read_keys, collect_step)
         return FilterStep(self.__should_accept, transform_step, commit_policy=ONCE_PER_SECOND)