From 22ad0eb9dafd985d7f753f6fad7d58734255c562 Mon Sep 17 00:00:00 2001 From: meredith Date: Wed, 20 Oct 2021 09:48:49 -0700 Subject: [PATCH] typing --- src/sentry/sentry_metrics/indexer/tasks.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/sentry/sentry_metrics/indexer/tasks.py b/src/sentry/sentry_metrics/indexer/tasks.py index c5fa2a99461780..27d504aa5486f4 100644 --- a/src/sentry/sentry_metrics/indexer/tasks.py +++ b/src/sentry/sentry_metrics/indexer/tasks.py @@ -1,4 +1,5 @@ import logging +from typing import Any, Dict, List from sentry.tasks.base import instrumented_task from sentry.utils import metrics @@ -6,11 +7,11 @@ 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")