diff --git a/zerver/worker/queue_processors.py b/zerver/worker/queue_processors.py index 699a5c534a..b7e82dc2ff 100644 --- a/zerver/worker/queue_processors.py +++ b/zerver/worker/queue_processors.py @@ -213,6 +213,8 @@ def retry_send_email_failures( class QueueProcessingWorker(ABC): queue_name: str MAX_CONSUME_SECONDS: Optional[int] = 30 + # The MAX_CONSUME_SECONDS timeout is only enabled when handling a + # single queue at once, with no threads. ENABLE_TIMEOUTS = False CONSUME_ITERATIONS_BEFORE_UPDATE_STATS_NUM = 50 MAX_SECONDS_BEFORE_UPDATE_STATS = 30