feat: Arroyo 2.4.0 (#43072)

requirements-base.txt

@@ -54,7 +54,7 @@ requests>=2.25.1
 rfc3339-validator>=0.1.2
 rfc3986-validator>=0.1.1
 # [end] jsonschema format validators
-sentry-arroyo>=2.3.1
+sentry-arroyo>=2.4.0
 sentry-relay>=0.8.15
 sentry-sdk>=1.11.0
 snuba-sdk>=1.0.3

requirements-dev-frozen.txt

@@ -10,6 +10,7 @@ amqp==2.6.1
 async-generator==1.10
 attrs==19.2.0
 avalara==20.9.0
+avro==1.11.1
 beautifulsoup4==4.7.1
 billiard==3.6.4.0
 black==22.10.0
@@ -154,7 +155,7 @@ rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.5.2
 selenium==4.3.0
-sentry-arroyo==2.3.1
+sentry-arroyo==2.4.0
 sentry-relay==0.8.15
 sentry-sdk==1.11.0
 simplejson==3.17.6

requirements-frozen.txt

@@ -10,6 +10,7 @@ amqp==2.6.1
 async-generator==1.10
 attrs==19.2.0
 avalara==20.9.0
+avro==1.11.1
 beautifulsoup4==4.7.1
 billiard==3.6.4.0
 boto3==1.22.12
@@ -108,7 +109,7 @@ rfc3986-validator==0.1.1
 rsa==4.8
 s3transfer==0.5.2
 selenium==4.3.0
-sentry-arroyo==2.3.1
+sentry-arroyo==2.4.0
 sentry-relay==0.8.15
 sentry-sdk==1.11.0
 simplejson==3.17.6

src/sentry/sentry_metrics/consumers/last_seen_updater.py

@@ -2,7 +2,7 @@ import datetime
 import functools
 from abc import abstractmethod
 from datetime import timedelta
-from typing import Any, Mapping, Optional, Set, Union
+from typing import Any, Callable, Mapping, Optional, Set, Union
 
 import rapidjson
 from arroyo.backends.kafka import KafkaConsumer, KafkaPayload
@@ -164,7 +164,7 @@ class LastSeenUpdaterStrategyFactory(ProcessingStrategyFactory[KafkaPayload]):
             result.update(value.payload)
             return result
 
-        initial_value: Set[int] = set()
+        initial_value: Callable[[], Set[int]] = lambda: set()
 
         def do_update(message: Message[Set[int]]) -> None:
             table = TABLE_MAPPING[self.__use_case_id]