Revert "do not use mypy-specific syntax in '# type: ignore' comments" (#6338)

This commit is contained in:
Akuli
2021-11-18 18:13:07 +00:00
committed by GitHub
parent 0d7064c357
commit 0cd1135219
7 changed files with 207 additions and 207 deletions

View File

@@ -17,7 +17,7 @@ if sys.version_info >= (3, 7):
def buffer_updated(self, nbytes: int) -> None: ...
class DatagramProtocol(BaseProtocol):
def connection_made(self, transport: transports.DatagramTransport) -> None: ... # type: ignore
def connection_made(self, transport: transports.DatagramTransport) -> None: ... # type: ignore[override]
def datagram_received(self, data: bytes, addr: tuple[str, int]) -> None: ...
def error_received(self, exc: Exception) -> None: ...

View File

@@ -4,4 +4,4 @@ from .base import Client as Client
class BackendApplicationClient(Client):
grant_type: str
def prepare_request_body(self, body: str = ..., scope: Any | None = ..., include_client_id: bool = ..., **kwargs): ... # type: ignore
def prepare_request_body(self, body: str = ..., scope: Any | None = ..., include_client_id: bool = ..., **kwargs): ... # type: ignore[override]

View File

@@ -5,6 +5,6 @@ from .base import Client as Client
class LegacyApplicationClient(Client):
grant_type: str
def __init__(self, client_id, **kwargs) -> None: ...
def prepare_request_body( # type: ignore
def prepare_request_body( # type: ignore[override]
self, username, password, body: str = ..., scope: Any | None = ..., include_client_id: bool = ..., **kwargs
): ...

View File

@@ -4,8 +4,8 @@ from .base import Client as Client
class MobileApplicationClient(Client):
response_type: str
def prepare_request_uri( # type: ignore
def prepare_request_uri( # type: ignore[override]
self, uri, redirect_uri: Any | None = ..., scope: Any | None = ..., state: Any | None = ..., **kwargs
): ...
token: Any
def parse_request_uri_response(self, uri, state: Any | None = ..., scope: Any | None = ...): ... # type: ignore
def parse_request_uri_response(self, uri, state: Any | None = ..., scope: Any | None = ...): ... # type: ignore[override]

View File

@@ -17,7 +17,7 @@ class ServiceApplicationClient(Client):
audience: Any | None = ...,
**kwargs,
) -> None: ...
def prepare_request_body( # type: ignore
def prepare_request_body( # type: ignore[override]
self,
private_key: Any | None = ...,
subject: Any | None = ...,

View File

@@ -6,10 +6,10 @@ class WebApplicationClient(Client):
grant_type: str
code: Any
def __init__(self, client_id, code: Any | None = ..., **kwargs) -> None: ...
def prepare_request_uri( # type: ignore
def prepare_request_uri( # type: ignore[override]
self, uri, redirect_uri: Any | None = ..., scope: Any | None = ..., state: Any | None = ..., **kwargs
): ...
def prepare_request_body( # type: ignore
def prepare_request_body( # type: ignore[override]
self, code: Any | None = ..., redirect_uri: Any | None = ..., body: str = ..., include_client_id: bool = ..., **kwargs
): ...
def parse_request_uri_response(self, uri, state: Any | None = ...): ... # type: ignore
def parse_request_uri_response(self, uri, state: Any | None = ...): ... # type: ignore[override]

View File

@@ -817,7 +817,7 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
scripts: Any
explicit_transaction: Any
def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...
def __enter__(self) -> Pipeline[_StrType]: ... # type: ignore
def __enter__(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def __exit__(self, exc_type, exc_value, traceback) -> None: ...
def __del__(self) -> None: ...
def __len__(self) -> int: ...
@@ -836,16 +836,16 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
def unwatch(self) -> bool: ...
# in the Redis implementation, the following methods are inherited from client.
def set_response_callback(self, command, callback): ...
def pipeline(self, transaction: bool = ..., shard_hint: Any = ...) -> Pipeline[_StrType]: ... # type: ignore
def pipeline(self, transaction: bool = ..., shard_hint: Any = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def lock(self, name, timeout=..., sleep=..., blocking_timeout=..., lock_class=..., thread_local=...): ...
def pubsub(self, shard_hint: Any = ..., ignore_subscribe_messages: bool = ...) -> PubSub: ...
def acl_cat(self, category: Text | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def acl_deluser(self, username: Text) -> Pipeline[_StrType]: ... # type: ignore
def acl_genpass(self) -> Pipeline[_StrType]: ... # type: ignore
def acl_getuser(self, username: Text) -> Pipeline[_StrType]: ... # type: ignore
def acl_list(self) -> Pipeline[_StrType]: ... # type: ignore
def acl_load(self) -> Pipeline[_StrType]: ... # type: ignore
def acl_setuser( # type: ignore
def acl_cat(self, category: Text | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_deluser(self, username: Text) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_genpass(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_getuser(self, username: Text) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_list(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_load(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_setuser( # type: ignore[override]
self,
username: Text = ...,
enabled: bool = ...,
@@ -859,81 +859,81 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
reset_keys: bool = ...,
reset_passwords: bool = ...,
) -> Pipeline[_StrType]: ...
def acl_users(self) -> Pipeline[_StrType]: ... # type: ignore
def acl_whoami(self) -> Pipeline[_StrType]: ... # type: ignore
def bgrewriteaof(self) -> Pipeline[_StrType]: ... # type: ignore
def bgsave(self) -> Pipeline[_StrType]: ... # type: ignore
def client_id(self) -> Pipeline[_StrType]: ... # type: ignore
def client_kill(self, address: Text) -> Pipeline[_StrType]: ... # type: ignore
def client_list(self) -> Pipeline[_StrType]: ... # type: ignore
def client_getname(self) -> Pipeline[_StrType]: ... # type: ignore
def client_setname(self, name: Text) -> Pipeline[_StrType]: ... # type: ignore
def readwrite(self) -> Pipeline[_StrType]: ... # type: ignore
def readonly(self) -> Pipeline[_StrType]: ... # type: ignore
def config_get(self, pattern=...) -> Pipeline[_StrType]: ... # type: ignore
def config_set(self, name, value) -> Pipeline[_StrType]: ... # type: ignore
def config_resetstat(self) -> Pipeline[_StrType]: ... # type: ignore
def config_rewrite(self) -> Pipeline[_StrType]: ... # type: ignore
def dbsize(self) -> Pipeline[_StrType]: ... # type: ignore
def debug_object(self, key) -> Pipeline[_StrType]: ... # type: ignore
def echo(self, value) -> Pipeline[_StrType]: ... # type: ignore
def flushall(self) -> Pipeline[_StrType]: ... # type: ignore
def flushdb(self) -> Pipeline[_StrType]: ... # type: ignore
def info(self, section: _Key | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def lastsave(self) -> Pipeline[_StrType]: ... # type: ignore
def object(self, infotype, key) -> Pipeline[_StrType]: ... # type: ignore
def ping(self) -> Pipeline[_StrType]: ... # type: ignore
def save(self) -> Pipeline[_StrType]: ... # type: ignore
def acl_users(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def acl_whoami(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def bgrewriteaof(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def bgsave(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def client_id(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def client_kill(self, address: Text) -> Pipeline[_StrType]: ... # type: ignore[override]
def client_list(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def client_getname(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def client_setname(self, name: Text) -> Pipeline[_StrType]: ... # type: ignore[override]
def readwrite(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def readonly(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_get(self, pattern=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_set(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_resetstat(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def config_rewrite(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def dbsize(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def debug_object(self, key) -> Pipeline[_StrType]: ... # type: ignore[override]
def echo(self, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def flushall(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def flushdb(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def info(self, section: _Key | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def lastsave(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def object(self, infotype, key) -> Pipeline[_StrType]: ... # type: ignore[override]
def ping(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def save(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel(self, *args) -> None: ...
def sentinel_get_master_addr_by_name(self, service_name) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_master(self, service_name) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_masters(self) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_remove(self, name) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_sentinels(self, service_name) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_set(self, name, option, value) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_slaves(self, service_name) -> Pipeline[_StrType]: ... # type: ignore
def sentinel_get_master_addr_by_name(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_master(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_masters(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_remove(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_sentinels(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_set(self, name, option, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def sentinel_slaves(self, service_name) -> Pipeline[_StrType]: ... # type: ignore[override]
def shutdown(self) -> None: ...
def slaveof(self, host=..., port=...) -> Pipeline[_StrType]: ... # type: ignore
def slowlog_get(self, num=...) -> Pipeline[_StrType]: ... # type: ignore
def slowlog_len(self) -> Pipeline[_StrType]: ... # type: ignore
def slowlog_reset(self) -> Pipeline[_StrType]: ... # type: ignore
def time(self) -> Pipeline[_StrType]: ... # type: ignore
def append(self, key, value) -> Pipeline[_StrType]: ... # type: ignore
def bitcount(self, key: _Key, start: int | None = ..., end: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ... # type: ignore
def bitpos(self, key, bit, start=..., end=...) -> Pipeline[_StrType]: ... # type: ignore
def decr(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore
def delete(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore
def slaveof(self, host=..., port=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_get(self, num=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_len(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def slowlog_reset(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def time(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def append(self, key, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitcount(self, key: _Key, start: int | None = ..., end: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ... # type: ignore[override]
def bitpos(self, key, bit, start=..., end=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def decr(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def delete(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __delitem__(self, _Key) -> None: ...
def dump(self, name) -> Pipeline[_StrType]: ... # type: ignore
def exists(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore
def __contains__(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore
def expire(self, name: _Key, time: int | timedelta) -> Pipeline[_StrType]: ... # type: ignore
def expireat(self, name, when) -> Pipeline[_StrType]: ... # type: ignore
def get(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def __getitem__(self, name) -> Pipeline[_StrType]: ... # type: ignore
def getbit(self, name: _Key, offset: int) -> Pipeline[_StrType]: ... # type: ignore
def getrange(self, key, start, end) -> Pipeline[_StrType]: ... # type: ignore
def getset(self, name, value) -> Pipeline[_StrType]: ... # type: ignore
def incr(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore
def incrby(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore
def incrbyfloat(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore
def keys(self, pattern: _Key = ...) -> Pipeline[_StrType]: ... # type: ignore
def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def mset(self, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore
def msetnx(self, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore
def move(self, name: _Key, db: int) -> Pipeline[_StrType]: ... # type: ignore
def persist(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def pexpire(self, name: _Key, time: int | timedelta) -> Pipeline[_StrType]: ... # type: ignore
def pexpireat(self, name: _Key, when: int | datetime) -> Pipeline[_StrType]: ... # type: ignore
def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ... # type: ignore
def pttl(self, name) -> Pipeline[_StrType]: ... # type: ignore
def randomkey(self) -> Pipeline[_StrType]: ... # type: ignore
def rename(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore
def renamenx(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore
def restore(self, name, ttl, value, replace: bool = ...) -> Pipeline[_StrType]: ... # type: ignore
def set( # type: ignore
def dump(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def exists(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __contains__(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def expire(self, name: _Key, time: int | timedelta) -> Pipeline[_StrType]: ... # type: ignore[override]
def expireat(self, name, when) -> Pipeline[_StrType]: ... # type: ignore[override]
def get(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def __getitem__(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def getbit(self, name: _Key, offset: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def getrange(self, key, start, end) -> Pipeline[_StrType]: ... # type: ignore[override]
def getset(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def incr(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def incrby(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def incrbyfloat(self, name, amount=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def keys(self, pattern: _Key = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def mset(self, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore[override]
def msetnx(self, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore[override]
def move(self, name: _Key, db: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def persist(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def pexpire(self, name: _Key, time: int | timedelta) -> Pipeline[_StrType]: ... # type: ignore[override]
def pexpireat(self, name: _Key, when: int | datetime) -> Pipeline[_StrType]: ... # type: ignore[override]
def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def pttl(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def randomkey(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def rename(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def renamenx(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def restore(self, name, ttl, value, replace: bool = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def set( # type: ignore[override]
self,
name: _Key,
value: _Value,
@@ -944,35 +944,35 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
keepttl: bool = ...,
) -> Pipeline[_StrType]: ...
def __setitem__(self, name, value) -> None: ...
def setbit(self, name: _Key, offset: int, value: int) -> Pipeline[_StrType]: ... # type: ignore
def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def setnx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore
def setrange(self, name, offset, value) -> Pipeline[_StrType]: ... # type: ignore
def strlen(self, name) -> Pipeline[_StrType]: ... # type: ignore
def substr(self, name, start, end=...) -> Pipeline[_StrType]: ... # type: ignore
def ttl(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def type(self, name) -> Pipeline[_StrType]: ... # type: ignore
def unlink(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore
def blpop(self, keys: _Value | Iterable[_Value], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore
def brpop(self, keys: _Value | Iterable[_Value], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore
def brpoplpush(self, src, dst, timeout=...) -> Pipeline[_StrType]: ... # type: ignore
def lindex(self, name: _Key, index: int) -> Pipeline[_StrType]: ... # type: ignore
def linsert( # type: ignore
def setbit(self, name: _Key, offset: int, value: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def setnx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def setrange(self, name, offset, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def strlen(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def substr(self, name, start, end=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def ttl(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def type(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def unlink(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def blpop(self, keys: _Value | Iterable[_Value], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def brpop(self, keys: _Value | Iterable[_Value], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def brpoplpush(self, src, dst, timeout=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def lindex(self, name: _Key, index: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def linsert( # type: ignore[override]
self, name: _Key, where: Literal["BEFORE", "AFTER", "before", "after"], refvalue: _Value, value: _Value
) -> Pipeline[_StrType]: ...
def llen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def lpop(self, name) -> Pipeline[_StrType]: ... # type: ignore
def lpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def lpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore
def lrange(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore
def lrem(self, name: _Key, count: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def lset(self, name: _Key, index: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def ltrim(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore
def rpop(self, name) -> Pipeline[_StrType]: ... # type: ignore
def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore
def rpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def rpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore
def sort( # type: ignore
def llen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpop(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lrange(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def lrem(self, name: _Key, count: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def lset(self, name: _Key, index: int, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def ltrim(self, name: _Key, start: int, end: int) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpop(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def rpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override]
def sort( # type: ignore[override]
self,
name: _Key,
start: int | None = ...,
@@ -984,62 +984,62 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
store: _Key | None = ...,
groups: bool = ...,
) -> Pipeline[_StrType]: ...
def scan(self, cursor: int = ..., match: _Key | None = ..., count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def scan(self, cursor: int = ..., match: _Key | None = ..., count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def scan_iter(self, match: Text | None = ..., count: int | None = ...) -> Iterator[Any]: ...
def sscan(self, name: _Key, cursor: int = ..., match: Text = ..., count: int = ...) -> Pipeline[_StrType]: ... # type: ignore
def sscan(self, name: _Key, cursor: int = ..., match: Text = ..., count: int = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def sscan_iter(self, name, match=..., count=...) -> Iterator[Any]: ...
def hscan(self, name: _Key, cursor: int = ..., match: Text = ..., count: int = ...) -> Pipeline[_StrType]: ... # type: ignore
def hscan(self, name: _Key, cursor: int = ..., match: Text = ..., count: int = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def hscan_iter(self, name, match=..., count=...) -> Iterator[Any]: ...
def zscan(self, name, cursor=..., match=..., count=..., score_cast_func=...) -> Pipeline[_StrType]: ... # type: ignore
def zscan(self, name, cursor=..., match=..., count=..., score_cast_func=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zscan_iter(self, name, match=..., count=..., score_cast_func=...) -> Iterator[Any]: ...
def sadd(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def scard(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sismember(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def smembers(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def smove(self, src: _Key, dst: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def spop(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def srandmember(self, name: _Key, number: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def srem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def xack(self, name, groupname, *ids) -> Pipeline[_StrType]: ... # type: ignore
def xadd(self, name, fields, id=..., maxlen=..., approximate=...) -> Pipeline[_StrType]: ... # type: ignore
def sadd(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def scard(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sismember(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def smembers(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def smove(self, src: _Key, dst: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def spop(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def srandmember(self, name: _Key, number: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def srem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def xack(self, name, groupname, *ids) -> Pipeline[_StrType]: ... # type: ignore[override]
def xadd(self, name, fields, id=..., maxlen=..., approximate=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xclaim(
self, name, groupname, consumername, min_idle_time, message_ids, idle=..., time=..., retrycount=..., force=..., justid=...
) -> Pipeline[_StrType]: ... # type: ignore
def xdel(self, name, *ids) -> Pipeline[_StrType]: ... # type: ignore
def xgroup_create(self, name, groupname, id=..., mkstream=...) -> Pipeline[_StrType]: ... # type: ignore
def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline[_StrType]: ... # type: ignore
def xgroup_destroy(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore
def xgroup_setid(self, name, groupname, id) -> Pipeline[_StrType]: ... # type: ignore
def xinfo_consumers(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore
def xinfo_groups(self, name) -> Pipeline[_StrType]: ... # type: ignore
def xinfo_stream(self, name) -> Pipeline[_StrType]: ... # type: ignore
def xlen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def xpending(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore
def xpending_range(self, name, groupname, min, max, count, consumername=...) -> Pipeline[_StrType]: ... # type: ignore
def xrange(self, name, min=..., max=..., count=...) -> Pipeline[_StrType]: ... # type: ignore
def xread(self, streams, count=..., block=...) -> Pipeline[_StrType]: ... # type: ignore
def xreadgroup(self, groupname, consumername, streams, count=..., block=..., noack=...) -> Pipeline[_StrType]: ... # type: ignore
def xrevrange(self, name, max=..., min=..., count=...) -> Pipeline[_StrType]: ... # type: ignore
def xtrim(self, name, maxlen, approximate=...) -> Pipeline[_StrType]: ... # type: ignore
def zadd( # type: ignore
) -> Pipeline[_StrType]: ... # type: ignore[override]
def xdel(self, name, *ids) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_create(self, name, groupname, id=..., mkstream=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_destroy(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xgroup_setid(self, name, groupname, id) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_consumers(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_groups(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def xinfo_stream(self, name) -> Pipeline[_StrType]: ... # type: ignore[override]
def xlen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def xpending(self, name, groupname) -> Pipeline[_StrType]: ... # type: ignore[override]
def xpending_range(self, name, groupname, min, max, count, consumername=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xrange(self, name, min=..., max=..., count=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xread(self, streams, count=..., block=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xreadgroup(self, groupname, consumername, streams, count=..., block=..., noack=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xrevrange(self, name, max=..., min=..., count=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def xtrim(self, name, maxlen, approximate=...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zadd( # type: ignore[override]
self, name: _Key, mapping: Mapping[_Key, _Value], nx: bool = ..., xx: bool = ..., ch: bool = ..., incr: bool = ...
) -> Pipeline[_StrType]: ...
def zcard(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def zcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zincrby(self, name: _Key, amount: float, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline[_StrType]: ... # type: ignore
def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zpopmax(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def zpopmin(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore
def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore
def zrange( # type: ignore
def zcard(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def zcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zincrby(self, name: _Key, amount: float, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zpopmax(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zpopmin(self, name: _Key, count: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zrange( # type: ignore[override]
self,
name: _Key,
start: int,
@@ -1048,8 +1048,8 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
withscores: bool = ...,
score_cast_func: Callable[[Any], Any] = ...,
) -> Pipeline[_StrType]: ...
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = ..., num: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore
def zrangebyscore( # type: ignore
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = ..., num: int | None = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def zrangebyscore( # type: ignore[override]
self,
name: _Key,
min: _Value,
@@ -1059,12 +1059,12 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
withscores: bool = ...,
score_cast_func: Callable[[Any], Any] = ...,
) -> Pipeline[_StrType]: ...
def zrank(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zrem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zremrangebyrank(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zrevrange( # type: ignore
def zrank(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zrem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zremrangebyrank(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zrevrange( # type: ignore[override]
self,
name: _Key,
start: int,
@@ -1073,7 +1073,7 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
withscores: bool = ...,
score_cast_func: Callable[[Any], Any] = ...,
) -> Pipeline[_StrType]: ...
def zrevrangebyscore( # type: ignore
def zrevrangebyscore( # type: ignore[override]
self,
name: _Key,
min: _Value,
@@ -1083,46 +1083,46 @@ class Pipeline(Redis[_StrType], Generic[_StrType]):
withscores: bool = ...,
score_cast_func: Callable[[Any], Any] = ...,
) -> Pipeline[_StrType]: ...
def zrevrangebylex( # type: ignore
def zrevrangebylex( # type: ignore[override]
self, name: _Key, min: _Value, max: _Value, start: int | None = ..., num: int | None = ...
) -> Pipeline[_StrType]: ...
def zrevrank(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zscore(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline[_StrType]: ... # type: ignore
def pfadd(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore
def pfcount(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def pfmerge(self, dest: _Key, *sources: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hdel(self, name: _Key, *keys: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hexists(self, name: _Key, key: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hget(self, name: _Key, key: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hgetall(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hincrby(self, name: _Key, key: _Key, amount: int = ...) -> Pipeline[_StrType]: ... # type: ignore
def hincrbyfloat(self, name: _Key, key: _Key, amount: float = ...) -> Pipeline[_StrType]: ... # type: ignore
def hkeys(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hlen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
@overload # type: ignore
def zrevrank(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zscore(self, name: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def pfadd(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def pfcount(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def pfmerge(self, dest: _Key, *sources: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hdel(self, name: _Key, *keys: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hexists(self, name: _Key, key: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hget(self, name: _Key, key: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hgetall(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hincrby(self, name: _Key, key: _Key, amount: int = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def hincrbyfloat(self, name: _Key, key: _Key, amount: float = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def hkeys(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hlen(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
@overload # type: ignore[override]
def hset(self, name: _Key, key: _Key, value: _Value, mapping: Mapping[_Key, _Value] | None = ...) -> Pipeline[_StrType]: ...
@overload # type: ignore
@overload # type: ignore[override]
def hset(self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ...
@overload # type: ignore
@overload # type: ignore[override]
def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ...
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore
def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def hvals(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore
def publish(self, channel: _Key, message: _Key) -> Pipeline[_StrType]: ... # type: ignore
def eval(self, script, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore
def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore
def script_exists(self, *args) -> Pipeline[_StrType]: ... # type: ignore
def script_flush(self) -> Pipeline[_StrType]: ... # type: ignore
def script_kill(self) -> Pipeline[_StrType]: ... # type: ignore
def script_load(self, script) -> Pipeline[_StrType]: ... # type: ignore
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Pipeline[_StrType]: ... # type: ignore[override]
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore[override]
def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def hvals(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def publish(self, channel: _Key, message: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def eval(self, script, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore[override]
def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_exists(self, *args) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_flush(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_kill(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def script_load(self, script) -> Pipeline[_StrType]: ... # type: ignore[override]
def register_script(self, script: Text | _StrType) -> Script: ...
def pubsub_channels(self, pattern: _Key = ...) -> Pipeline[_StrType]: ... # type: ignore
def pubsub_numsub(self, *args: _Key) -> Pipeline[_StrType]: ... # type: ignore
def pubsub_numpat(self) -> Pipeline[_StrType]: ... # type: ignore
def pubsub_channels(self, pattern: _Key = ...) -> Pipeline[_StrType]: ... # type: ignore[override]
def pubsub_numsub(self, *args: _Key) -> Pipeline[_StrType]: ... # type: ignore[override]
def pubsub_numpat(self) -> Pipeline[_StrType]: ... # type: ignore[override]
def monitor(self) -> Monitor: ...
def cluster(self, cluster_arg: str, *args: Any) -> Pipeline[_StrType]: ... # type: ignore
def cluster(self, cluster_arg: str, *args: Any) -> Pipeline[_StrType]: ... # type: ignore[override]
def client(self) -> Any: ...
class Script: