typing

getsentry · Oct 26, 2021 · 22ad0eb · 22ad0eb
1 parent 7551200
commit 22ad0eb
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/sentry/sentry_metrics/indexer/tasks.py b/src/sentry/sentry_metrics/indexer/tasks.py
@@ -1,16 +1,17 @@
 import logging
+from typing import Any, Dict, List
 
 from sentry.tasks.base import instrumented_task
 from sentry.utils import metrics
 
 logger = logging.getLogger(__name__)
 
 
-@instrumented_task(
+@instrumented_task(  # type: ignore
     name="sentry.sentry_metrics.indexer.tasks.process_indexed_metrics",
     queue="sentry_metrics.indexer",
     default_retry_delay=5,
     max_retries=5,
 )
-def process_indexed_metrics(messages, **kwargs):
+def process_indexed_metrics(messages: List[Dict[str, Any]], **kwargs: Any) -> None:
     metrics.incr("sentry_metrics.indexer.task.processed_messages")