diff --git a/zerver/worker/queue_processors.py b/zerver/worker/queue_processors.py index fa7048debf..68e4909022 100644 --- a/zerver/worker/queue_processors.py +++ b/zerver/worker/queue_processors.py @@ -75,7 +75,7 @@ def assign_queue( return clazz return decorate -worker_classes = {} # type: Dict[str, Any] # Any here should be QueueProcessingWorker type +worker_classes = {} # type: Dict[str, Type[QueueProcessingWorker]] queues = {} # type: Dict[str, Dict[str, Type[QueueProcessingWorker]]] def register_worker(queue_name: str, clazz: Type['QueueProcessingWorker'], queue_type: str) -> None: if queue_type not in queues: