diff --git a/zerver/worker/queue_processors.py b/zerver/worker/queue_processors.py
index 3a7356f502..5437bafc88 100644
--- a/zerver/worker/queue_processors.py
+++ b/zerver/worker/queue_processors.py
@@ -152,7 +152,7 @@ def check_and_send_restart_signal() -> None:
 
 def retry_send_email_failures(
         func: Callable[[ConcreteQueueWorker, Dict[str, Any]], None],
-) -> Callable[['QueueProcessingWorker', Dict[str, Any]], None]:
+) -> Callable[[ConcreteQueueWorker, Dict[str, Any]], None]:
 
     @wraps(func)
     def wrapper(worker: ConcreteQueueWorker, data: Dict[str, Any]) -> None: