chore(issues): Enable stronger typing on occurrence_consumer (#70487)

This is a quick follow up to #69828 since these two type errors are trivial to resolve.
getsentry · May 9, 2024 · cc7a7d1 · cc7a7d1
1 parent 0696a68
commit cc7a7d1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pyproject.toml b/pyproject.toml
@@ -582,6 +582,7 @@ module = [
     "sentry.issues.issue_occurrence",
     "sentry.issues.json_schemas",
     "sentry.issues.merge",
+    "sentry.issues.occurrence_consumer",
     "sentry.issues.ongoing",
     "sentry.issues.priority",
     "sentry.issues.producer",

diff --git a/src/sentry/issues/occurrence_consumer.py b/src/sentry/issues/occurrence_consumer.py
@@ -364,7 +364,7 @@ def _process_message(
     return None
 
 
-def _process_batch(worker: ThreadPoolExecutor, message: Message[ValuesBatch[KafkaPayload]]):
+def _process_batch(worker: ThreadPoolExecutor, message: Message[ValuesBatch[KafkaPayload]]) -> None:
     """
     Receives batches of occurrences. This function will take the batch
     and group them together by fingerprint (ensuring order is preserved) and
@@ -402,7 +402,7 @@ def _process_batch(worker: ThreadPoolExecutor, message: Message[ValuesBatch[Kafk
         wait(futures)
 
 
-def process_occurrence_group(items: list[Mapping[str, Any]]):
+def process_occurrence_group(items: list[Mapping[str, Any]]) -> None:
     """
     Process a group of related occurrences (all part of the same group)
     completely serially.