queue_processors: Fix retry_send_email_failures type.

Signed-off-by: Anders Kaseorg <anders@zulip.com>
This commit is contained in:
Anders Kaseorg 2021-01-26 10:56:16 -08:00
parent 70aa9903b9
commit 454144c35f
1 changed files with 1 additions and 1 deletions

View File

@ -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: