From b04e50d52262a028308300d7dabc64a04497a818 Mon Sep 17 00:00:00 2001 From: Alex Waygood Date: Thu, 23 Nov 2023 13:02:25 +0000 Subject: [PATCH] redis: remove unused `type: ignore`s (#11062) --- stubs/redis/redis/asyncio/client.pyi | 548 ++++++++++++----------- stubs/redis/redis/asyncio/connection.pyi | 2 +- stubs/redis/redis/asyncio/sentinel.pyi | 2 +- stubs/redis/redis/client.pyi | 143 +++--- stubs/redis/redis/commands/core.pyi | 2 +- 5 files changed, 364 insertions(+), 333 deletions(-) diff --git a/stubs/redis/redis/asyncio/client.pyi b/stubs/redis/redis/asyncio/client.pyi index 31006fd36..11e7b95cc 100644 --- a/stubs/redis/redis/asyncio/client.pyi +++ b/stubs/redis/redis/asyncio/client.pyi @@ -314,7 +314,7 @@ class Pipeline(Redis[_StrType]): def __await__(self) -> Generator[Any, None, Self]: ... def __len__(self) -> int: ... def __bool__(self) -> bool: ... - async def reset(self) -> None: ... # type: ignore[override] + async def reset(self) -> None: ... def multi(self) -> None: ... def execute_command(self, *args, **kwargs) -> Pipeline[_StrType] | Awaitable[Pipeline[_StrType]]: ... async def immediate_execute_command(self, *args, **options): ... @@ -328,16 +328,16 @@ class Pipeline(Redis[_StrType]): async def watch(self, *names: KeyT) -> bool: ... async def unwatch(self) -> bool: ... # region acl commands - def acl_cat(self, category: str | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_deluser(self, *username: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_genpass(self, bits: int | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_getuser(self, username: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_help(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_list(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_log(self, count: int | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_log_reset(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_load(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_save(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] + def acl_cat(self, category: str | None = None, **kwargs: _CommandOptions) -> Any: ... + def acl_deluser(self, *username: str, **kwargs: _CommandOptions) -> Any: ... + def acl_genpass(self, bits: int | None = None, **kwargs: _CommandOptions) -> Any: ... + def acl_getuser(self, username: str, **kwargs: _CommandOptions) -> Any: ... + def acl_help(self, **kwargs: _CommandOptions) -> Any: ... + def acl_list(self, **kwargs: _CommandOptions) -> Any: ... + def acl_log(self, count: int | None = None, **kwargs: _CommandOptions) -> Any: ... + def acl_log_reset(self, **kwargs: _CommandOptions) -> Any: ... + def acl_load(self, **kwargs: _CommandOptions) -> Any: ... + def acl_save(self, **kwargs: _CommandOptions) -> Any: ... def acl_setuser( # type: ignore[override] self, username: str, @@ -356,33 +356,33 @@ class Pipeline(Redis[_StrType]): reset_passwords: bool = False, **kwargs: _CommandOptions, ) -> Pipeline[_StrType]: ... - def acl_users(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def acl_whoami(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] + def acl_users(self, **kwargs: _CommandOptions) -> Any: ... + def acl_whoami(self, **kwargs: _CommandOptions) -> Any: ... # endregion # region cluster commands - def cluster(self, cluster_arg: str, *args, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def readwrite(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def readonly(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] + def cluster(self, cluster_arg: str, *args, **kwargs: _CommandOptions) -> Any: ... + def readwrite(self, **kwargs: _CommandOptions) -> Any: ... + def readonly(self, **kwargs: _CommandOptions) -> Any: ... # endregion # region BasicKey commands - def append(self, key, value) -> Any: ... # type: ignore[override] - def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... # type: ignore[override] - def bitfield(self, key, default_overflow: Incomplete | None = None) -> Any: ... # type: ignore[override] - def bitop(self, operation, dest, *keys) -> Any: ... # type: ignore[override] - def bitpos(self, key: _Key, bit: int, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... # type: ignore[override] - def copy(self, source, destination, destination_db: Incomplete | None = None, replace: bool = False) -> Any: ... # type: ignore[override] - def decr(self, name, amount: int = 1) -> Any: ... # type: ignore[override] - def decrby(self, name, amount: int = 1) -> Any: ... # type: ignore[override] - def delete(self, *names: _Key) -> Any: ... # type: ignore[override] - def dump(self, name: _Key) -> Any: ... # type: ignore[override] - def exists(self, *names: _Key) -> Any: ... # type: ignore[override] - def expire( # type: ignore[override] + def append(self, key, value) -> Any: ... + def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... + def bitfield(self, key, default_overflow: Incomplete | None = None) -> Any: ... + def bitop(self, operation, dest, *keys) -> Any: ... + def bitpos(self, key: _Key, bit: int, start: int | None = None, end: int | None = None, mode: str | None = None) -> Any: ... + def copy(self, source, destination, destination_db: Incomplete | None = None, replace: bool = False) -> Any: ... + def decr(self, name, amount: int = 1) -> Any: ... + def decrby(self, name, amount: int = 1) -> Any: ... + def delete(self, *names: _Key) -> Any: ... + def dump(self, name: _Key) -> Any: ... + def exists(self, *names: _Key) -> Any: ... + def expire( self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False ) -> Any: ... - def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Any: ... # type: ignore[override] - def get(self, name: _Key) -> Any: ... # type: ignore[override] - def getdel(self, name: _Key) -> Any: ... # type: ignore[override] - def getex( # type: ignore[override] + def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Any: ... + def get(self, name: _Key) -> Any: ... + def getdel(self, name: _Key) -> Any: ... + def getex( self, name, ex: Incomplete | None = None, @@ -391,21 +391,21 @@ class Pipeline(Redis[_StrType]): pxat: Incomplete | None = None, persist: bool = False, ) -> Any: ... - def getbit(self, name: _Key, offset: int) -> Any: ... # type: ignore[override] - def getrange(self, key, start, end) -> Any: ... # type: ignore[override] - def getset(self, name, value) -> Any: ... # type: ignore[override] - def incr(self, name: _Key, amount: int = 1) -> Any: ... # type: ignore[override] - def incrby(self, name: _Key, amount: int = 1) -> Any: ... # type: ignore[override] - def incrbyfloat(self, name: _Key, amount: float = 1.0) -> Any: ... # type: ignore[override] - def keys(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def lmove( # type: ignore[override] + def getbit(self, name: _Key, offset: int) -> Any: ... + def getrange(self, key, start, end) -> Any: ... + def getset(self, name, value) -> Any: ... + def incr(self, name: _Key, amount: int = 1) -> Any: ... + def incrby(self, name: _Key, amount: int = 1) -> Any: ... + def incrbyfloat(self, name: _Key, amount: float = 1.0) -> Any: ... + def keys(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... + def lmove( self, first_list: _Key, second_list: _Key, src: Literal["LEFT", "RIGHT"] = "LEFT", dest: Literal["LEFT", "RIGHT"] = "RIGHT", ) -> Any: ... - def blmove( # type: ignore[override] + def blmove( self, first_list: _Key, second_list: _Key, @@ -413,24 +413,24 @@ class Pipeline(Redis[_StrType]): src: Literal["LEFT", "RIGHT"] = "LEFT", dest: Literal["LEFT", "RIGHT"] = "RIGHT", ) -> Any: ... - def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def mset(self, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override] - def msetnx(self, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override] - def move(self, name: _Key, db: int) -> Any: ... # type: ignore[override] - def persist(self, name: _Key) -> Any: ... # type: ignore[override] - def pexpire( # type: ignore[override] + def mget(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def mset(self, mapping: Mapping[_Key, _Value]) -> Any: ... + def msetnx(self, mapping: Mapping[_Key, _Value]) -> Any: ... + def move(self, name: _Key, db: int) -> Any: ... + def persist(self, name: _Key) -> Any: ... + def pexpire( self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False ) -> Any: ... - def pexpireat( # type: ignore[override] + def pexpireat( self, name: _Key, when: int | datetime, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False ) -> Any: ... - def psetex(self, name, time_ms, value) -> Any: ... # type: ignore[override] - def pttl(self, name: _Key) -> Any: ... # type: ignore[override] - def hrandfield(self, key, count: Incomplete | None = None, withvalues: bool = False) -> Any: ... # type: ignore[override] - def randomkey(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def rename(self, src, dst) -> Any: ... # type: ignore[override] - def renamenx(self, src, dst) -> Any: ... # type: ignore[override] - def restore( # type: ignore[override] + def psetex(self, name, time_ms, value) -> Any: ... + def pttl(self, name: _Key) -> Any: ... + def hrandfield(self, key, count: Incomplete | None = None, withvalues: bool = False) -> Any: ... + def randomkey(self, **kwargs: _CommandOptions) -> Any: ... + def rename(self, src, dst) -> Any: ... + def renamenx(self, src, dst) -> Any: ... + def restore( self, name, ttl, @@ -453,11 +453,11 @@ class Pipeline(Redis[_StrType]): exat: Incomplete | None = None, pxat: Incomplete | None = None, ) -> Any: ... - def setbit(self, name: _Key, offset: int, value: int) -> Any: ... # type: ignore[override] - def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Any: ... # type: ignore[override] - def setnx(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override] - def setrange(self, name, offset, value) -> Any: ... # type: ignore[override] - def stralgo( # type: ignore[override] + def setbit(self, name: _Key, offset: int, value: int) -> Any: ... + def setex(self, name: _Key, time: int | timedelta, value: _Value) -> Any: ... + def setnx(self, name: _Key, value: _Value) -> Any: ... + def setrange(self, name, offset, value) -> Any: ... + def stralgo( self, algo, value1, @@ -469,47 +469,49 @@ class Pipeline(Redis[_StrType]): withmatchlen: bool = False, **kwargs: _CommandOptions, ) -> Any: ... - def strlen(self, name) -> Any: ... # type: ignore[override] - def substr(self, name, start, end: int = -1) -> Any: ... # type: ignore[override] - def touch(self, *args) -> Any: ... # type: ignore[override] - def ttl(self, name: _Key) -> Any: ... # type: ignore[override] - def type(self, name) -> Any: ... # type: ignore[override] - def unlink(self, *names: _Key) -> Any: ... # type: ignore[override] + def strlen(self, name) -> Any: ... + def substr(self, name, start, end: int = -1) -> Any: ... + def touch(self, *args) -> Any: ... + def ttl(self, name: _Key) -> Any: ... + def type(self, name) -> Any: ... + def unlink(self, *names: _Key) -> Any: ... # endregion # region hyperlog commands - def pfadd(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override] - def pfcount(self, name: _Key) -> Any: ... # type: ignore[override] - def pfmerge(self, dest: _Key, *sources: _Key) -> Any: ... # type: ignore[override] + def pfadd(self, name: _Key, *values: _Value) -> Any: ... + def pfcount(self, name: _Key) -> Any: ... + def pfmerge(self, dest: _Key, *sources: _Key) -> Any: ... # endregion # region hash commands - def hdel(self, name: _Key, *keys: _Key) -> Any: ... # type: ignore[override] - def hexists(self, name: _Key, key: _Key) -> Any: ... # type: ignore[override] - def hget(self, name: _Key, key: _Key) -> Any: ... # type: ignore[override] - def hgetall(self, name: _Key) -> Any: ... # type: ignore[override] - def hincrby(self, name: _Key, key: _Key, amount: int = 1) -> Any: ... # type: ignore[override] - def hincrbyfloat(self, name: _Key, key: _Key, amount: float = 1.0) -> Any: ... # type: ignore[override] - def hkeys(self, name: _Key) -> Any: ... # type: ignore[override] - def hlen(self, name: _Key) -> Any: ... # type: ignore[override] + def hdel(self, name: _Key, *keys: _Key) -> Any: ... + def hexists(self, name: _Key, key: _Key) -> Any: ... + def hget(self, name: _Key, key: _Key) -> Any: ... + def hgetall(self, name: _Key) -> Any: ... + def hincrby(self, name: _Key, key: _Key, amount: int = 1) -> Any: ... + def hincrbyfloat(self, name: _Key, key: _Key, amount: float = 1.0) -> Any: ... + def hkeys(self, name: _Key) -> Any: ... + def hlen(self, name: _Key) -> Any: ... @overload - def hset( # type: ignore[override] + def hset( self, name: _Key, key: _Key, value: _Value, mapping: Mapping[_Key, _Value] | None = None, items: Incomplete | None = None ) -> Any: ... @overload - def hset(self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ... # type: ignore[override] + def hset( + self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None + ) -> Any: ... @overload - def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ... # type: ignore[override] - def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Any: ... # type: ignore[override] - def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Any: ... # type: ignore[override] - def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def hvals(self, name: _Key) -> Any: ... # type: ignore[override] - def hstrlen(self, name, key) -> Any: ... # type: ignore[override] + def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Any: ... + def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Any: ... + def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Any: ... + def hmget(self, name: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def hvals(self, name: _Key) -> Any: ... + def hstrlen(self, name, key) -> Any: ... # endregion # region geo commands - def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False) -> Any: ... # type: ignore[override] - def geodist(self, name, place1, place2, unit: Incomplete | None = None) -> Any: ... # type: ignore[override] - def geohash(self, name, *values) -> Any: ... # type: ignore[override] - def geopos(self, name, *values) -> Any: ... # type: ignore[override] - def georadius( # type: ignore[override] + def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False) -> Any: ... + def geodist(self, name, place1, place2, unit: Incomplete | None = None) -> Any: ... + def geohash(self, name, *values) -> Any: ... + def geopos(self, name, *values) -> Any: ... + def georadius( self, name, longitude, @@ -525,7 +527,7 @@ class Pipeline(Redis[_StrType]): store_dist: Incomplete | None = None, any: bool = False, ) -> Any: ... - def georadiusbymember( # type: ignore[override] + def georadiusbymember( self, name, member, @@ -540,7 +542,7 @@ class Pipeline(Redis[_StrType]): store_dist: Incomplete | None = None, any: bool = False, ) -> Any: ... - def geosearch( # type: ignore[override] + def geosearch( self, name, member: Incomplete | None = None, @@ -557,7 +559,7 @@ class Pipeline(Redis[_StrType]): withdist: bool = False, withhash: bool = False, ) -> Any: ... - def geosearchstore( # type: ignore[override] + def geosearchstore( self, dest, name, @@ -576,31 +578,33 @@ class Pipeline(Redis[_StrType]): # endregion # region list commands @overload - def blpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... # type: ignore[override] + def blpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... @overload - def blpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... # type: ignore[override] + def blpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... @overload - def brpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... # type: ignore[override] + def brpop(self, keys: _Value | Iterable[_Value], timeout: Literal[0] | None = 0) -> Any: ... @overload - def brpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... # type: ignore[override] - def brpoplpush(self, src, dst, timeout: int | None = 0) -> Any: ... # type: ignore[override] - def lindex(self, name: _Key, index: int) -> Any: ... # type: ignore[override] - def linsert( # type: ignore[override] + def brpop(self, keys: _Value | Iterable[_Value], timeout: float) -> Any: ... + def brpoplpush(self, src, dst, timeout: int | None = 0) -> Any: ... + def lindex(self, name: _Key, index: int) -> Any: ... + def linsert( self, name: _Key, where: Literal["BEFORE", "AFTER", "before", "after"], refvalue: _Value, value: _Value ) -> Any: ... - def llen(self, name: _Key) -> Any: ... # type: ignore[override] - def lpop(self, name, count: int | None = None) -> Any: ... # type: ignore[override] - def lpush(self, name: _Value, *values: _Value) -> Any: ... # type: ignore[override] - def lpushx(self, name, value) -> Any: ... # type: ignore[override] - def lrange(self, name: _Key, start: int, end: int) -> Any: ... # type: ignore[override] - def lrem(self, name: _Key, count: int, value: _Value) -> Any: ... # type: ignore[override] - def lset(self, name: _Key, index: int, value: _Value) -> Any: ... # type: ignore[override] - def ltrim(self, name: _Key, start: int, end: int) -> Any: ... # type: ignore[override] - def rpop(self, name, count: int | None = None) -> Any: ... # type: ignore[override] - def rpoplpush(self, src, dst) -> Any: ... # type: ignore[override] - def rpush(self, name: _Value, *values: _Value) -> Any: ... # type: ignore[override] - def rpushx(self, name, value) -> Any: ... # type: ignore[override] - def lpos(self, name, value, rank: Incomplete | None = None, count: Incomplete | None = None, maxlen: Incomplete | None = None) -> Any: ... # type: ignore[override] + def llen(self, name: _Key) -> Any: ... + def lpop(self, name, count: int | None = None) -> Any: ... + def lpush(self, name: _Value, *values: _Value) -> Any: ... + def lpushx(self, name, value) -> Any: ... + def lrange(self, name: _Key, start: int, end: int) -> Any: ... + def lrem(self, name: _Key, count: int, value: _Value) -> Any: ... + def lset(self, name: _Key, index: int, value: _Value) -> Any: ... + def ltrim(self, name: _Key, start: int, end: int) -> Any: ... + def rpop(self, name, count: int | None = None) -> Any: ... + def rpoplpush(self, src, dst) -> Any: ... + def rpush(self, name: _Value, *values: _Value) -> Any: ... + def rpushx(self, name, value) -> Any: ... + def lpos( + self, name, value, rank: Incomplete | None = None, count: Incomplete | None = None, maxlen: Incomplete | None = None + ) -> Any: ... @overload # type: ignore[override] def sort( self, @@ -614,7 +618,7 @@ class Pipeline(Redis[_StrType]): store: None = None, groups: bool = False, ) -> list[_StrType]: ... - @overload # type: ignore[override] + @overload def sort( self, name: _Key, @@ -628,7 +632,7 @@ class Pipeline(Redis[_StrType]): store: _Key, groups: bool = False, ) -> Any: ... - @overload # type: ignore[override] + @overload def sort( self, name: _Key, @@ -643,7 +647,7 @@ class Pipeline(Redis[_StrType]): ) -> Any: ... # endregion # region scan commands - def scan( # type: ignore[override] + def scan( self, cursor: int = 0, match: _Key | None = None, @@ -651,11 +655,11 @@ class Pipeline(Redis[_StrType]): _type: str | None = None, **kwargs: _CommandOptions, ) -> Any: ... - def sscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... # type: ignore[override] - def hscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... # type: ignore[override] - @overload # type: ignore[override] + def sscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... + def hscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... + @overload def zscan(self, name: _Key, cursor: int = 0, match: _Key | None = None, count: int | None = None) -> Any: ... - @overload # type: ignore[override] + @overload def zscan( self, name: _Key, @@ -665,37 +669,37 @@ class Pipeline(Redis[_StrType]): *, score_cast_func: Callable[[_StrType], Any], ) -> Any: ... - @overload # type: ignore[override] + @overload def zscan( self, name: _Key, cursor: int, match: _Key | None, count: int | None, score_cast_func: Callable[[_StrType], Any] ) -> Any: ... # endregion # region set commands - def sadd(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override] - def scard(self, name: _Key) -> Any: ... # type: ignore[override] - def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def sismember(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override] - def smembers(self, name: _Key) -> Any: ... # type: ignore[override] - def smismember(self, name, values, *args) -> Any: ... # type: ignore[override] - def smove(self, src: _Key, dst: _Key, value: _Value) -> Any: ... # type: ignore[override] - @overload # type: ignore[override] + def sadd(self, name: _Key, *values: _Value) -> Any: ... + def scard(self, name: _Key) -> Any: ... + def sdiff(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def sdiffstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def sinter(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def sinterstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def sismember(self, name: _Key, value: _Value) -> Any: ... + def smembers(self, name: _Key) -> Any: ... + def smismember(self, name, values, *args) -> Any: ... + def smove(self, src: _Key, dst: _Key, value: _Value) -> Any: ... + @overload def spop(self, name: _Key, count: None = None) -> Any: ... - @overload # type: ignore[override] + @overload def spop(self, name: _Key, count: int) -> Any: ... - @overload # type: ignore[override] + @overload def srandmember(self, name: _Key, number: None = None) -> Any: ... - @overload # type: ignore[override] + @overload def srandmember(self, name: _Key, number: int) -> Any: ... - def srem(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override] - def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] - def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # type: ignore[override] + def srem(self, name: _Key, *values: _Value) -> Any: ... + def sunion(self, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... + def sunionstore(self, dest: _Key, keys: _Key | Iterable[_Key], *args: _Key) -> Any: ... # endregion # region stream commands - def xack(self, name, groupname, *ids) -> Any: ... # type: ignore[override] - def xadd( # type: ignore[override] + def xack(self, name, groupname, *ids) -> Any: ... + def xadd( self, name, fields, @@ -706,7 +710,7 @@ class Pipeline(Redis[_StrType]): minid: Incomplete | None = None, limit: Incomplete | None = None, ) -> Any: ... - def xautoclaim( # type: ignore[override] + def xautoclaim( self, name, groupname, @@ -716,7 +720,7 @@ class Pipeline(Redis[_StrType]): count: Incomplete | None = None, justid: bool = False, ) -> Any: ... - def xclaim( # type: ignore[override] + def xclaim( self, name, groupname, @@ -729,23 +733,23 @@ class Pipeline(Redis[_StrType]): force=False, justid=False, ) -> Any: ... - def xdel(self, name, *ids) -> Any: ... # type: ignore[override] - def xgroup_create(self, name, groupname, id: str = "$", mkstream: bool = False, entries_read: int | None = None) -> Any: ... # type: ignore[override] - def xgroup_delconsumer(self, name, groupname, consumername) -> Any: ... # type: ignore[override] - def xgroup_destroy(self, name, groupname) -> Any: ... # type: ignore[override] - def xgroup_createconsumer(self, name, groupname, consumername) -> Any: ... # type: ignore[override] - def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Any: ... # type: ignore[override] - def xinfo_consumers(self, name, groupname) -> Any: ... # type: ignore[override] - def xinfo_groups(self, name) -> Any: ... # type: ignore[override] - def xinfo_stream(self, name, full: bool = False) -> Any: ... # type: ignore[override] - def xlen(self, name: _Key) -> Any: ... # type: ignore[override] - def xpending(self, name, groupname) -> Any: ... # type: ignore[override] - def xpending_range( # type: ignore[override] + def xdel(self, name, *ids) -> Any: ... + def xgroup_create(self, name, groupname, id: str = "$", mkstream: bool = False, entries_read: int | None = None) -> Any: ... + def xgroup_delconsumer(self, name, groupname, consumername) -> Any: ... + def xgroup_destroy(self, name, groupname) -> Any: ... + def xgroup_createconsumer(self, name, groupname, consumername) -> Any: ... + def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Any: ... + def xinfo_consumers(self, name, groupname) -> Any: ... + def xinfo_groups(self, name) -> Any: ... + def xinfo_stream(self, name, full: bool = False) -> Any: ... + def xlen(self, name: _Key) -> Any: ... + def xpending(self, name, groupname) -> Any: ... + def xpending_range( self, name: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None ) -> Any: ... - def xrange(self, name, min: str = "-", max: str = "+", count: Incomplete | None = None) -> Any: ... # type: ignore[override] - def xread(self, streams, count: Incomplete | None = None, block: Incomplete | None = None) -> Any: ... # type: ignore[override] - def xreadgroup( # type: ignore[override] + def xrange(self, name, min: str = "-", max: str = "+", count: Incomplete | None = None) -> Any: ... + def xread(self, streams, count: Incomplete | None = None, block: Incomplete | None = None) -> Any: ... + def xreadgroup( self, groupname, consumername, @@ -754,13 +758,13 @@ class Pipeline(Redis[_StrType]): block: Incomplete | None = None, noack: bool = False, ) -> Any: ... - def xrevrange(self, name, max: str = "+", min: str = "-", count: Incomplete | None = None) -> Any: ... # type: ignore[override] - def xtrim( # type: ignore[override] + def xrevrange(self, name, max: str = "+", min: str = "-", count: Incomplete | None = None) -> Any: ... + def xtrim( self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None ) -> Any: ... # endregion # region sorted set commands - def zadd( # type: ignore[override] + def zadd( self, name: _Key, mapping: Mapping[_Key, _Value], @@ -771,24 +775,24 @@ class Pipeline(Redis[_StrType]): gt: Incomplete | None = False, lt: Incomplete | None = False, ) -> Any: ... - def zcard(self, name: _Key) -> Any: ... # type: ignore[override] - def zcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override] - def zdiff(self, keys, withscores: bool = False) -> Any: ... # type: ignore[override] - def zdiffstore(self, dest, keys) -> Any: ... # type: ignore[override] - def zincrby(self, name: _Key, amount: float, value: _Value) -> Any: ... # type: ignore[override] - def zinter(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override] - def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... # type: ignore[override] - def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override] - def zpopmax(self, name: _Key, count: int | None = None) -> Any: ... # type: ignore[override] - def zpopmin(self, name: _Key, count: int | None = None) -> Any: ... # type: ignore[override] - def zrandmember(self, key, count: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override] - @overload # type: ignore[override] + def zcard(self, name: _Key) -> Any: ... + def zcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... + def zdiff(self, keys, withscores: bool = False) -> Any: ... + def zdiffstore(self, dest, keys) -> Any: ... + def zincrby(self, name: _Key, amount: float, value: _Value) -> Any: ... + def zinter(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... + def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... + def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Any: ... + def zpopmax(self, name: _Key, count: int | None = None) -> Any: ... + def zpopmin(self, name: _Key, count: int | None = None) -> Any: ... + def zrandmember(self, key, count: Incomplete | None = None, withscores: bool = False) -> Any: ... + @overload def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: Literal[0] = 0) -> Any: ... - @overload # type: ignore[override] + @overload def bzpopmax(self, keys: _Key | Iterable[_Key], timeout: float) -> Any: ... - @overload # type: ignore[override] + @overload def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: Literal[0] = 0) -> Any: ... - @overload # type: ignore[override] + @overload def bzpopmin(self, keys: _Key | Iterable[_Key], timeout: float) -> Any: ... @overload # type: ignore[override] def zrange( @@ -804,7 +808,7 @@ class Pipeline(Redis[_StrType]): offset: int | None = None, num: int | None = None, ) -> Any: ... - @overload # type: ignore[override] + @overload def zrange( self, name: _Key, @@ -818,7 +822,7 @@ class Pipeline(Redis[_StrType]): offset: int | None = None, num: int | None = None, ) -> Any: ... - @overload # type: ignore[override] + @overload def zrange( self, name: _Key, @@ -832,7 +836,7 @@ class Pipeline(Redis[_StrType]): offset: int | None = None, num: int | None = None, ) -> Any: ... - @overload # type: ignore[override] + @overload def zrange( self, name: _Key, @@ -846,7 +850,7 @@ class Pipeline(Redis[_StrType]): offset: int | None = None, num: int | None = None, ) -> Any: ... - @overload # type: ignore[override] + @overload def zrange( self, name: _Key, @@ -864,13 +868,13 @@ class Pipeline(Redis[_StrType]): def zrevrange( self, name: _Key, start: int, end: int, withscores: Literal[True], score_cast_func: Callable[[_StrType], None] ) -> Any: ... - @overload # type: ignore[override] + @overload def zrevrange(self, name: _Key, start: int, end: int, withscores: Literal[True]) -> Any: ... - @overload # type: ignore[override] + @overload def zrevrange( self, name: _Key, start: int, end: int, withscores: bool = False, score_cast_func: Callable[[Any], Any] = ... ) -> Any: ... - def zrangestore( # type: ignore[override] + def zrangestore( self, dest, name, @@ -882,8 +886,8 @@ class Pipeline(Redis[_StrType]): offset: Incomplete | None = None, num: Incomplete | None = None, ) -> Any: ... - def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None) -> Any: ... # type: ignore[override] - def zrevrangebylex(self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None) -> Any: ... # type: ignore[override] + def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None) -> Any: ... + def zrevrangebylex(self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None) -> Any: ... @overload # type: ignore[override] def zrangebyscore( self, @@ -896,11 +900,11 @@ class Pipeline(Redis[_StrType]): withscores: Literal[True], score_cast_func: Callable[[_StrType], None], ) -> Any: ... - @overload # type: ignore[override] + @overload def zrangebyscore( self, name: _Key, min: _Value, max: _Value, start: int | None = None, num: int | None = None, *, withscores: Literal[True] ) -> Any: ... - @overload # type: ignore[override] + @overload def zrangebyscore( self, name: _Key, @@ -911,7 +915,7 @@ class Pipeline(Redis[_StrType]): withscores: bool = False, score_cast_func: Callable[[_StrType], Any] = ..., ) -> Any: ... - @overload # type: ignore[override] + @overload def zrevrangebyscore( self, name: _Key, @@ -923,11 +927,11 @@ class Pipeline(Redis[_StrType]): withscores: Literal[True], score_cast_func: Callable[[_StrType], Any], ) -> Any: ... - @overload # type: ignore[override] + @overload def zrevrangebyscore( self, name: _Key, max: _Value, min: _Value, start: int | None = None, num: int | None = None, *, withscores: Literal[True] ) -> Any: ... - @overload # type: ignore[override] + @overload def zrevrangebyscore( self, name: _Key, @@ -938,23 +942,23 @@ class Pipeline(Redis[_StrType]): withscores: bool = False, score_cast_func: Callable[[_StrType], Any] = ..., ) -> Any: ... - def zrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... # type: ignore[override] - def zrem(self, name: _Key, *values: _Value) -> Any: ... # type: ignore[override] - def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override] - def zremrangebyrank(self, name: _Key, min: int, max: int) -> Any: ... # type: ignore[override] - def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Any: ... # type: ignore[override] - def zrevrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... # type: ignore[override] - def zscore(self, name: _Key, value: _Value) -> Any: ... # type: ignore[override] - def zunion(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... # type: ignore[override] - def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... # type: ignore[override] - def zmscore(self, key, members) -> Any: ... # type: ignore[override] + def zrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... + def zrem(self, name: _Key, *values: _Value) -> Any: ... + def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Any: ... + def zremrangebyrank(self, name: _Key, min: int, max: int) -> Any: ... + def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Any: ... + def zrevrank(self, name: _Key, value: _Value, withscore: bool = False) -> Any: ... + def zscore(self, name: _Key, value: _Value) -> Any: ... + def zunion(self, keys, aggregate: Incomplete | None = None, withscores: bool = False) -> Any: ... + def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] | None = None) -> Any: ... + def zmscore(self, key, members) -> Any: ... # endregion # region management commands - def bgrewriteaof(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def bgsave(self, schedule: bool = True, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def role(self) -> Any: ... # type: ignore[override] - def client_kill(self, address: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_kill_filter( # type: ignore[override] + def bgrewriteaof(self, **kwargs: _CommandOptions) -> Any: ... + def bgsave(self, schedule: bool = True, **kwargs: _CommandOptions) -> Any: ... + def role(self) -> Any: ... + def client_kill(self, address: str, **kwargs: _CommandOptions) -> Any: ... + def client_kill_filter( self, _id: Incomplete | None = None, _type: Incomplete | None = None, @@ -964,13 +968,13 @@ class Pipeline(Redis[_StrType]): user: Incomplete | None = None, **kwargs: _CommandOptions, ) -> Any: ... - def client_info(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_list(self, _type: str | None = None, client_id: list[str] = [], **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_getname(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_getredir(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_reply(self, reply, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_id(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_tracking_on( # type: ignore[override] + def client_info(self, **kwargs: _CommandOptions) -> Any: ... + def client_list(self, _type: str | None = None, client_id: list[str] = [], **kwargs: _CommandOptions) -> Any: ... + def client_getname(self, **kwargs: _CommandOptions) -> Any: ... + def client_getredir(self, **kwargs: _CommandOptions) -> Any: ... + def client_reply(self, reply, **kwargs: _CommandOptions) -> Any: ... + def client_id(self, **kwargs: _CommandOptions) -> Any: ... + def client_tracking_on( self, clientid: Incomplete | None = None, prefix=[], @@ -979,7 +983,7 @@ class Pipeline(Redis[_StrType]): optout: bool = False, noloop: bool = False, ) -> Any: ... - def client_tracking_off( # type: ignore[override] + def client_tracking_off( self, clientid: Incomplete | None = None, prefix=[], @@ -988,7 +992,7 @@ class Pipeline(Redis[_StrType]): optout: bool = False, noloop: bool = False, ) -> Any: ... - def client_tracking( # type: ignore[override] + def client_tracking( self, on: bool = True, clientid: Incomplete | None = None, @@ -999,32 +1003,32 @@ class Pipeline(Redis[_StrType]): noloop: bool = False, **kwargs: _CommandOptions, ) -> Any: ... - def client_trackinginfo(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_setname(self, name: str, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_unblock(self, client_id, error: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_pause(self, timeout, all: bool = True, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def client_unpause(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def command(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def command_info(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def command_count(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def config_resetstat(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def config_rewrite(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def dbsize(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def debug_object(self, key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def debug_segfault(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def echo(self, value: _Value, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def flushall(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def flushdb(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def sync(self) -> Any: ... # type: ignore[override] - def psync(self, replicationid, offset) -> Any: ... # type: ignore[override] - def swapdb(self, first, second, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def select(self, index, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def info(self, section: _Key | None = None, *args: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def lastsave(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def lolwut(self, *version_numbers: _Value, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def migrate( # type: ignore[override] + def client_trackinginfo(self, **kwargs: _CommandOptions) -> Any: ... + def client_setname(self, name: str, **kwargs: _CommandOptions) -> Any: ... + def client_unblock(self, client_id, error: bool = False, **kwargs: _CommandOptions) -> Any: ... + def client_pause(self, timeout, all: bool = True, **kwargs: _CommandOptions) -> Any: ... + def client_unpause(self, **kwargs: _CommandOptions) -> Any: ... + def command(self, **kwargs: _CommandOptions) -> Any: ... + def command_info(self, **kwargs: _CommandOptions) -> Any: ... + def command_count(self, **kwargs: _CommandOptions) -> Any: ... + def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Any: ... + def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Any: ... + def config_resetstat(self, **kwargs: _CommandOptions) -> Any: ... + def config_rewrite(self, **kwargs: _CommandOptions) -> Any: ... + def dbsize(self, **kwargs: _CommandOptions) -> Any: ... + def debug_object(self, key, **kwargs: _CommandOptions) -> Any: ... + def debug_segfault(self, **kwargs: _CommandOptions) -> Any: ... + def echo(self, value: _Value, **kwargs: _CommandOptions) -> Any: ... + def flushall(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... + def flushdb(self, asynchronous: bool = False, **kwargs: _CommandOptions) -> Any: ... + def sync(self) -> Any: ... + def psync(self, replicationid, offset) -> Any: ... + def swapdb(self, first, second, **kwargs: _CommandOptions) -> Any: ... + def select(self, index, **kwargs: _CommandOptions) -> Any: ... + def info(self, section: _Key | None = None, *args: _Key, **kwargs: _CommandOptions) -> Any: ... + def lastsave(self, **kwargs: _CommandOptions) -> Any: ... + def lolwut(self, *version_numbers: _Value, **kwargs: _CommandOptions) -> Any: ... + def migrate( self, host, port, @@ -1036,18 +1040,18 @@ class Pipeline(Redis[_StrType]): auth: Incomplete | None = None, **kwargs: _CommandOptions, ) -> Any: ... - def object(self, infotype, key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_doctor(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_help(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_stats(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_malloc_stats(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_usage(self, key, samples: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def memory_purge(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def ping(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def quit(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def replicaof(self, *args, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def save(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def shutdown( # type: ignore[override] + def object(self, infotype, key, **kwargs: _CommandOptions) -> Any: ... + def memory_doctor(self, **kwargs: _CommandOptions) -> Any: ... + def memory_help(self, **kwargs: _CommandOptions) -> Any: ... + def memory_stats(self, **kwargs: _CommandOptions) -> Any: ... + def memory_malloc_stats(self, **kwargs: _CommandOptions) -> Any: ... + def memory_usage(self, key, samples: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... + def memory_purge(self, **kwargs: _CommandOptions) -> Any: ... + def ping(self, **kwargs: _CommandOptions) -> Any: ... + def quit(self, **kwargs: _CommandOptions) -> Any: ... + def replicaof(self, *args, **kwargs: _CommandOptions) -> Any: ... + def save(self, **kwargs: _CommandOptions) -> Any: ... + def shutdown( self, save: bool = False, nosave: bool = False, @@ -1056,32 +1060,32 @@ class Pipeline(Redis[_StrType]): abort: bool = False, **kwargs: _CommandOptions, ) -> Any: ... - def slaveof(self, host: Incomplete | None = None, port: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def slowlog_get(self, num: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def slowlog_len(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def slowlog_reset(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def time(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def wait(self, num_replicas, timeout, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] + def slaveof(self, host: Incomplete | None = None, port: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... + def slowlog_get(self, num: Incomplete | None = None, **kwargs: _CommandOptions) -> Any: ... + def slowlog_len(self, **kwargs: _CommandOptions) -> Any: ... + def slowlog_reset(self, **kwargs: _CommandOptions) -> Any: ... + def time(self, **kwargs: _CommandOptions) -> Any: ... + def wait(self, num_replicas, timeout, **kwargs: _CommandOptions) -> Any: ... # endregion # region module commands - def module_load(self, path, *args) -> Any: ... # type: ignore[override] - def module_unload(self, name) -> Any: ... # type: ignore[override] - def module_list(self) -> Any: ... # type: ignore[override] - def command_getkeys(self, *args) -> Any: ... # type: ignore[override] + def module_load(self, path, *args) -> Any: ... + def module_unload(self, name) -> Any: ... + def module_list(self) -> Any: ... + def command_getkeys(self, *args) -> Any: ... # endregion # region pubsub commands - def publish(self, channel: _Key, message: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def pubsub_channels(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def pubsub_numpat(self, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] - def pubsub_numsub(self, *args: _Key, **kwargs: _CommandOptions) -> Any: ... # type: ignore[override] + def publish(self, channel: _Key, message: _Key, **kwargs: _CommandOptions) -> Any: ... + def pubsub_channels(self, pattern: _Key = "*", **kwargs: _CommandOptions) -> Any: ... + def pubsub_numpat(self, **kwargs: _CommandOptions) -> Any: ... + def pubsub_numsub(self, *args: _Key, **kwargs: _CommandOptions) -> Any: ... # endregion # region script commands - def eval(self, script, numkeys, *keys_and_args) -> Any: ... # type: ignore[override] - def evalsha(self, sha, numkeys, *keys_and_args) -> Any: ... # type: ignore[override] - def script_exists(self, *args) -> Any: ... # type: ignore[override] - def script_debug(self, *args) -> Any: ... # type: ignore[override] - def script_flush(self, sync_type: Incomplete | None = None) -> Any: ... # type: ignore[override] - def script_kill(self) -> Any: ... # type: ignore[override] - def script_load(self, script) -> Any: ... # type: ignore[override] + def eval(self, script, numkeys, *keys_and_args) -> Any: ... + def evalsha(self, sha, numkeys, *keys_and_args) -> Any: ... + def script_exists(self, *args) -> Any: ... + def script_debug(self, *args) -> Any: ... + def script_flush(self, sync_type: Incomplete | None = None) -> Any: ... + def script_kill(self) -> Any: ... + def script_load(self, script) -> Any: ... def register_script(self, script: str | _StrType) -> Any: ... # type: ignore[override] # endregion diff --git a/stubs/redis/redis/asyncio/connection.pyi b/stubs/redis/redis/asyncio/connection.pyi index 441a64a56..d771ff093 100644 --- a/stubs/redis/redis/asyncio/connection.pyi +++ b/stubs/redis/redis/asyncio/connection.pyi @@ -60,7 +60,7 @@ class HiredisParser(BaseParser): def on_connect(self, connection: Connection): ... def on_disconnect(self) -> None: ... async def read_from_socket(self) -> Literal[True]: ... - async def read_response(self, disable_decoding: bool = False) -> EncodableT | list[EncodableT]: ... # type: ignore[override] + async def read_response(self, disable_decoding: bool = False) -> EncodableT | list[EncodableT]: ... DefaultParser: type[PythonParser | HiredisParser] diff --git a/stubs/redis/redis/asyncio/sentinel.pyi b/stubs/redis/redis/asyncio/sentinel.pyi index dd9a92114..a25a30cbd 100644 --- a/stubs/redis/redis/asyncio/sentinel.pyi +++ b/stubs/redis/redis/asyncio/sentinel.pyi @@ -16,7 +16,7 @@ class SentinelManagedConnection(Connection): def __init__(self, **kwargs) -> None: ... async def connect_to(self, address) -> None: ... async def connect(self): ... - @overload # type: ignore[override] + @overload async def read_response(self, *, timeout: float, disconnect_on_error: bool = True) -> Incomplete | None: ... @overload async def read_response( diff --git a/stubs/redis/redis/client.pyi b/stubs/redis/redis/client.pyi index 871d11587..f01d8651f 100644 --- a/stubs/redis/redis/client.pyi +++ b/stubs/redis/redis/client.pyi @@ -397,7 +397,7 @@ class Pipeline(Redis[_StrType]): scripts: Any explicit_transaction: Any def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ... - def __enter__(self) -> Pipeline[_StrType]: ... # type: ignore[override] + def __enter__(self) -> Pipeline[_StrType]: ... def __exit__( self, exc_type: type[BaseException] | None, exc_value: BaseException | None, traceback: TracebackType | None ) -> None: ... @@ -419,7 +419,7 @@ class Pipeline(Redis[_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 = True, shard_hint: Any = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def pipeline(self, transaction: bool = True, shard_hint: Any = None) -> Pipeline[_StrType]: ... def acl_cat(self, category: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] def acl_deluser(self, username: str) -> Pipeline[_StrType]: ... # type: ignore[override] def acl_genpass(self, bits: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] @@ -455,8 +455,10 @@ class Pipeline(Redis[_StrType]): def client_setname(self, name: str) -> 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: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ... # type: ignore[override] - def config_set(self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ... # type: ignore[override] + def config_get(self, pattern: PatternT = "*", *args: PatternT, **kwargs: _CommandOptions) -> Pipeline[_StrType]: ... + def config_set( + self, name: KeyT, value: EncodableT, *args: KeyT | EncodableT, **kwargs: _CommandOptions + ) -> Pipeline[_StrType]: ... 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] @@ -469,23 +471,23 @@ class Pipeline(Redis[_StrType]): 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_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 sentinel_get_master_addr_by_name(self, service_name) -> Pipeline[_StrType]: ... + def sentinel_master(self, service_name) -> Pipeline[_StrType]: ... + def sentinel_masters(self) -> Pipeline[_StrType]: ... + def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline[_StrType]: ... + def sentinel_remove(self, name) -> Pipeline[_StrType]: ... + def sentinel_sentinels(self, service_name) -> Pipeline[_StrType]: ... + def sentinel_set(self, name, option, value) -> Pipeline[_StrType]: ... + def sentinel_slaves(self, service_name) -> Pipeline[_StrType]: ... def slaveof(self, host=None, port=None) -> Pipeline[_StrType]: ... # type: ignore[override] def slowlog_get(self, num=None) -> 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 append(self, key, value) -> Pipeline[_StrType]: ... def bitcount(self, key: _Key, start: int | None = None, end: int | None = None, mode: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] - def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ... # type: ignore[override] - def bitpos(self, key, bit, start=None, end=None, mode: str | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def bitop(self, operation, dest, *keys) -> Pipeline[_StrType]: ... + def bitpos(self, key, bit, start=None, end=None, mode: str | None = None) -> Pipeline[_StrType]: ... def decr(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override] def delete(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override] def __delitem__(self, _Key) -> None: ... @@ -493,11 +495,13 @@ class Pipeline(Redis[_StrType]): 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, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override] - def expireat(self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override] + def expireat( + self, name, when, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False + ) -> Pipeline[_StrType]: ... def get(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override] - def __getitem__(self, name) -> Pipeline[_StrType]: ... # type: ignore[override] + def __getitem__(self, name) -> Pipeline[_StrType]: ... def getbit(self, name: _Key, offset: int) -> Pipeline[_StrType]: ... # type: ignore[override] - def getrange(self, key, start, end) -> Pipeline[_StrType]: ... # type: ignore[override] + def getrange(self, key, start, end) -> Pipeline[_StrType]: ... def getset(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override] def incr(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override] def incrby(self, name, amount=1) -> Pipeline[_StrType]: ... # type: ignore[override] @@ -510,12 +514,21 @@ class Pipeline(Redis[_StrType]): def persist(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override] def pexpire(self, name: _Key, time: int | timedelta, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override] def pexpireat(self, name: _Key, when: int | datetime, nx: bool = False, xx: bool = False, gt: bool = False, lt: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override] - def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ... # type: ignore[override] + def psetex(self, name, time_ms, value) -> Pipeline[_StrType]: ... 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 = False, absttl: bool = False, idletime: Incomplete | None = None, frequency: Incomplete | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def rename(self, src, dst) -> Pipeline[_StrType]: ... + def renamenx(self, src, dst) -> Pipeline[_StrType]: ... + def restore( + self, + name, + ttl, + value, + replace: bool = False, + absttl: bool = False, + idletime: Incomplete | None = None, + frequency: Incomplete | None = None, + ) -> Pipeline[_StrType]: ... def set( # type: ignore[override] self, name: _Key, @@ -533,11 +546,11 @@ class Pipeline(Redis[_StrType]): 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=-1) -> Pipeline[_StrType]: ... # type: ignore[override] + def setrange(self, name, offset, value) -> Pipeline[_StrType]: ... + def strlen(self, name) -> Pipeline[_StrType]: ... + def substr(self, name, start, end=-1) -> Pipeline[_StrType]: ... def ttl(self, name: _Key) -> Pipeline[_StrType]: ... # type: ignore[override] - def type(self, name) -> Pipeline[_StrType]: ... # type: ignore[override] + def type(self, name) -> Pipeline[_StrType]: ... def unlink(self, *names: _Key) -> Pipeline[_StrType]: ... # type: ignore[override] def blmove( # type: ignore[override] self, @@ -549,7 +562,7 @@ class Pipeline(Redis[_StrType]): ) -> Pipeline[_StrType]: ... def blpop(self, keys: _Value | Iterable[_Value], timeout: float = 0) -> Pipeline[_StrType]: ... # type: ignore[override] def brpop(self, keys: _Value | Iterable[_Value], timeout: float = 0) -> Pipeline[_StrType]: ... # type: ignore[override] - def brpoplpush(self, src, dst, timeout=0) -> Pipeline[_StrType]: ... # type: ignore[override] + def brpoplpush(self, src, dst, timeout=0) -> Pipeline[_StrType]: ... 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 @@ -562,17 +575,17 @@ class Pipeline(Redis[_StrType]): src: Literal["LEFT", "RIGHT"] = "LEFT", dest: Literal["LEFT", "RIGHT"] = "RIGHT", ) -> Pipeline[_StrType]: ... - def lpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def lpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ... def lpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override] - def lpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override] + def lpushx(self, name, value) -> Pipeline[_StrType]: ... 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, count: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] - def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ... # type: ignore[override] + def rpop(self, name, count: int | None = None) -> Pipeline[_StrType]: ... + def rpoplpush(self, src, dst) -> Pipeline[_StrType]: ... def rpush(self, name: _Value, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore[override] - def rpushx(self, name, value) -> Pipeline[_StrType]: ... # type: ignore[override] + def rpushx(self, name, value) -> Pipeline[_StrType]: ... def sort( # type: ignore[override] self, name: _Key, @@ -608,8 +621,18 @@ class Pipeline(Redis[_StrType]): 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=None, approximate: bool = True, nomkstream: bool = False, minid: Incomplete | None = None, limit: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def xack(self, name, groupname, *ids) -> Pipeline[_StrType]: ... + def xadd( + self, + name, + fields, + id="*", + maxlen=None, + approximate: bool = True, + nomkstream: bool = False, + minid: Incomplete | None = None, + limit: int | None = None, + ) -> Pipeline[_StrType]: ... def xclaim( self, name, @@ -622,23 +645,27 @@ class Pipeline(Redis[_StrType]): retrycount=None, force=False, justid=False, - ) -> Pipeline[_StrType]: ... # type: ignore[override] - def xdel(self, name, *ids) -> Pipeline[_StrType]: ... # type: ignore[override] - def xgroup_create(self, name, groupname, id="$", mkstream=False, entries_read: int | None = None) -> 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, entries_read: int | None = None) -> 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, full: bool = False) -> Pipeline[_StrType]: ... # type: ignore[override] + ) -> Pipeline[_StrType]: ... + def xdel(self, name, *ids) -> Pipeline[_StrType]: ... + def xgroup_create(self, name, groupname, id="$", mkstream=False, entries_read: int | None = None) -> Pipeline[_StrType]: ... + def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline[_StrType]: ... + def xgroup_destroy(self, name, groupname) -> Pipeline[_StrType]: ... + def xgroup_setid(self, name, groupname, id, entries_read: int | None = None) -> Pipeline[_StrType]: ... + def xinfo_consumers(self, name, groupname) -> Pipeline[_StrType]: ... + def xinfo_groups(self, name) -> Pipeline[_StrType]: ... + def xinfo_stream(self, name, full: bool = False) -> Pipeline[_StrType]: ... 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: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] - def xrange(self, name, min="-", max="+", count=None) -> Pipeline[_StrType]: ... # type: ignore[override] - def xread(self, streams, count=None, block=None) -> Pipeline[_StrType]: ... # type: ignore[override] - def xreadgroup(self, groupname, consumername, streams, count=None, block=None, noack=False) -> Pipeline[_StrType]: ... # type: ignore[override] - def xrevrange(self, name, max="+", min="-", count=None) -> Pipeline[_StrType]: ... # type: ignore[override] - def xtrim(self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None) -> Pipeline[_StrType]: ... # type: ignore[override] + def xpending(self, name, groupname) -> Pipeline[_StrType]: ... + def xpending_range( + self, name: _Key, groupname, min, max, count: int, consumername: Incomplete | None = None, idle: int | None = None + ) -> Pipeline[_StrType]: ... + def xrange(self, name, min="-", max="+", count=None) -> Pipeline[_StrType]: ... + def xread(self, streams, count=None, block=None) -> Pipeline[_StrType]: ... + def xreadgroup(self, groupname, consumername, streams, count=None, block=None, noack=False) -> Pipeline[_StrType]: ... + def xrevrange(self, name, max="+", min="-", count=None) -> Pipeline[_StrType]: ... + def xtrim( + self, name, maxlen: int | None = None, approximate: bool = True, minid: Incomplete | None = None, limit: int | None = None + ) -> Pipeline[_StrType]: ... def zadd( # type: ignore[override] self, name: _Key, @@ -722,23 +749,23 @@ class Pipeline(Redis[_StrType]): def hset( self, name: _Key, key: _Key, value: _Value, mapping: Mapping[_Key, _Value] | None = None, items: Incomplete | None = None ) -> Pipeline[_StrType]: ... - @overload # type: ignore[override] + @overload def hset( self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value], items: Incomplete | None = None ) -> Pipeline[_StrType]: ... - @overload # type: ignore[override] + @overload def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value], items: Incomplete | None = None) -> Pipeline[_StrType]: ... 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, sync_type: Incomplete | None = None) -> 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 eval(self, script, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... + def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline[_StrType]: ... + def script_exists(self, *args) -> Pipeline[_StrType]: ... + def script_flush(self, sync_type: Incomplete | None = None) -> Pipeline[_StrType]: ... + def script_kill(self) -> Pipeline[_StrType]: ... + def script_load(self, script) -> Pipeline[_StrType]: ... 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] diff --git a/stubs/redis/redis/commands/core.pyi b/stubs/redis/redis/commands/core.pyi index 70a4d1885..9d72bf0a6 100644 --- a/stubs/redis/redis/commands/core.pyi +++ b/stubs/redis/redis/commands/core.pyi @@ -1490,7 +1490,7 @@ class AsyncScriptCommands(Generic[_StrType]): async def script_flush(self, sync_type: Incomplete | None = None): ... async def script_kill(self): ... async def script_load(self, script): ... - def register_script(self, script: ScriptTextT) -> AsyncScript: ... # type: ignore[override] + def register_script(self, script: ScriptTextT) -> AsyncScript: ... class GeoCommands: def geoadd(self, name, values, nx: bool = False, xx: bool = False, ch: bool = False): ...