Hints to static analysis

Author: kcons

src/sentry/taskworker/retry.py

@@ -2,6 +2,7 @@
 
 from enum import Enum
 from multiprocessing.context import TimeoutError
+from typing import NoReturn
 
 from celery import current_task
 from sentry_protos.taskbroker.v1.taskbroker_pb2 import (
@@ -41,7 +42,7 @@ def to_proto(self) -> OnAttemptsExceeded.ValueType:
         raise ValueError(f"Unknown LastAction: {self}")
 
 
-def retry_task(exc: Exception | None = None) -> None:
+def retry_task(exc: Exception | None = None) -> NoReturn:
     """
     Helper for triggering retry errors.
     If all retries have been consumed, this will raise a
@@ -55,6 +56,7 @@ def retry_task(exc: Exception | None = None) -> None:
     celery_retry = getattr(current_task, "retry", None)
     if celery_retry:
         current_task.retry(exc=exc)
+        assert False, "unreachable"
     else:
         current = taskworker_current_task()
         if current and not current.retries_remaining: