fix: failed mypy (#17886)

This commit is contained in:
ofekisr
2021-12-29 16:05:53 +02:00
committed by GitHub
parent c6c4143b04
commit ef57bd1902
2 changed files with 5 additions and 4 deletions

View File

@@ -176,9 +176,7 @@ class AsyncQueryManager:
) -> List[Optional[Dict[str, Any]]]:
stream_name = f"{self._stream_prefix}{channel}"
start_id = increment_id(last_id) if last_id else "-"
results = self._redis.xrange( # type: ignore
stream_name, start_id, "+", self.MAX_EVENT_COUNT
)
results = self._redis.xrange(stream_name, start_id, "+", self.MAX_EVENT_COUNT)
return [] if not results else list(map(parse_event, results))
def update_job(