paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-11 17:36:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

queue_processors: Simplify unnecessary use of Optional.

Browse Source 
Signed-off-by: Anders Kaseorg <anders@zulip.com>
This commit is contained in:
Anders Kaseorg
2021-04-12 14:52:10 -07:00
committed by Tim Abbott
parent 9a2140d60e
commit 1fe29aad42
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
zerver/worker/queue_processors.py
View File

@@ -27,6 +27,7 @@ from typing import (
Mapping, Mapping,
MutableSequence, MutableSequence,
Optional, Optional,
Sequence,
Set, Set,
Tuple, Tuple,
Type, Type,
@@ -913,10 +914,10 @@ class TestWorker(QueueProcessingWorker):
class NoopWorker(QueueProcessingWorker): class NoopWorker(QueueProcessingWorker):
"""Used to profile the queue processing framework, in zilencer's queue_rate.""" """Used to profile the queue processing framework, in zilencer's queue_rate."""
def __init__(self, max_consume: int = 1000, slow_queries: Optional[List[int]] = None) -> None: def __init__(self, max_consume: int = 1000, slow_queries: Sequence[int] = []) -> None:
self.consumed = 0 self.consumed = 0
self.max_consume = max_consume self.max_consume = max_consume
self.slow_queries: Set[int] = set(slow_queries or []) self.slow_queries: Set[int] = set(slow_queries)
def consume(self, event: Mapping[str, Any]) -> None: def consume(self, event: Mapping[str, Any]) -> None:
self.consumed += 1 self.consumed += 1
@@ -934,10 +935,10 @@ class BatchNoopWorker(LoopQueueProcessingWorker):
batch_size = 500 batch_size = 500
def __init__(self, max_consume: int = 1000, slow_queries: Optional[List[int]] = None) -> None: def __init__(self, max_consume: int = 1000, slow_queries: Sequence[int] = []) -> None:
self.consumed = 0 self.consumed = 0
self.max_consume = max_consume self.max_consume = max_consume
self.slow_queries: Set[int] = set(slow_queries or []) self.slow_queries: Set[int] = set(slow_queries)
def consume_batch(self, events: List[Dict[str, Any]]) -> None: def consume_batch(self, events: List[Dict[str, Any]]) -> None:
event_numbers = set(range(self.consumed + 1, self.consumed + 1 + len(events))) event_numbers = set(range(self.consumed + 1, self.consumed + 1 + len(events)))