mirror of
https://github.com/davidhalter/typeshed.git
synced 2026-02-25 02:57:14 +08:00
Enable pyright for all Python 3 stubs (#5597)
* pyright: disable reportUnknownParameterType Unknown parameter types are preferred over Any annotations for incomplete stubs. Especially larger stubs are expected to be incomplete for some time and it would be a shame to lose the other pyright warnings for those stubs. * Also disable reportUnknownVariableType Fix problems with tkinter * Disable reportUnknownMemberType Fix pyright problems
This commit is contained in:
Sebastian Rittau
@@ -357,7 +357,7 @@ class Redis(Generic[_StrType]):
|
||||
username: Optional[Text] = ...,
|
||||
) -> None: ...
|
||||
def set_response_callback(self, command, callback): ...
|
||||
def pipeline(self, transaction: bool = ..., shard_hint: Any = ...) -> Pipeline: ...
|
||||
def pipeline(self, transaction: bool = ..., shard_hint: Any = ...) -> Pipeline[_StrType]: ...
|
||||
def transaction(self, func, *watches, **kwargs): ...
|
||||
@overload
|
||||
def lock(
|
||||
@@ -779,11 +779,11 @@ class Redis(Generic[_StrType]):
|
||||
def pubsub_numpat(self) -> int: ...
|
||||
def monitor(self) -> Monitor: ...
|
||||
def cluster(self, cluster_arg: str, *args: Any) -> Any: ...
|
||||
def __enter__(self) -> Redis: ...
|
||||
def __enter__(self) -> Redis[_StrType]: ...
|
||||
def __exit__(self, exc_type, exc_value, traceback): ...
|
||||
def __del__(self) -> None: ...
|
||||
def close(self) -> None: ...
|
||||
def client(self) -> Redis: ...
|
||||
def client(self) -> Redis[_StrType]: ...
|
||||
|
||||
StrictRedis = Redis
|
||||
|
||||
@@ -819,7 +819,7 @@ class PubSub:
|
||||
def run_in_thread(self, sleep_time=...): ...
|
||||
def ping(self, message: Optional[_Value] = ...) -> None: ...
|
||||
|
||||
class Pipeline(Redis):
|
||||
class Pipeline(Redis[_StrType], Generic[_StrType]):
|
||||
UNWATCH_COMMANDS: Any
|
||||
connection_pool: Any
|
||||
connection: Any
|
||||
@@ -832,7 +832,7 @@ class Pipeline(Redis):
|
||||
scripts: Any
|
||||
explicit_transaction: Any
|
||||
def __init__(self, connection_pool, response_callbacks, transaction, shard_hint) -> None: ...
|
||||
def __enter__(self) -> Pipeline: ... # type: ignore [override]
|
||||
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: ...
|
||||
@@ -851,15 +851,15 @@ class Pipeline(Redis):
|
||||
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: ... # type: ignore [override]
|
||||
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: Optional[Text] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_deluser(self, username: Text) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_genpass(self) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_getuser(self, username: Text) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_list(self) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_load(self) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_cat(self, category: Optional[Text] = ...) -> 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 = ...,
|
||||
@@ -873,81 +873,81 @@ class Pipeline(Redis):
|
||||
reset: bool = ...,
|
||||
reset_keys: bool = ...,
|
||||
reset_passwords: bool = ...,
|
||||
) -> Pipeline: ...
|
||||
def acl_users(self) -> Pipeline: ... # type: ignore [override]
|
||||
def acl_whoami(self) -> Pipeline: ... # type: ignore [override]
|
||||
def bgrewriteaof(self) -> Pipeline: ... # type: ignore [override]
|
||||
def bgsave(self) -> Pipeline: ... # type: ignore [override]
|
||||
def client_id(self) -> Pipeline: ... # type: ignore [override]
|
||||
def client_kill(self, address: Text) -> Pipeline: ... # type: ignore [override]
|
||||
def client_list(self) -> Pipeline: ... # type: ignore [override]
|
||||
def client_getname(self) -> Pipeline: ... # type: ignore [override]
|
||||
def client_setname(self, name: Text) -> Pipeline: ... # type: ignore [override]
|
||||
def readwrite(self) -> Pipeline: ... # type: ignore [override]
|
||||
def readonly(self) -> Pipeline: ... # type: ignore [override]
|
||||
def config_get(self, pattern=...) -> Pipeline: ... # type: ignore [override]
|
||||
def config_set(self, name, value) -> Pipeline: ... # type: ignore [override]
|
||||
def config_resetstat(self) -> Pipeline: ... # type: ignore [override]
|
||||
def config_rewrite(self) -> Pipeline: ... # type: ignore [override]
|
||||
def dbsize(self) -> Pipeline: ... # type: ignore [override]
|
||||
def debug_object(self, key) -> Pipeline: ... # type: ignore [override]
|
||||
def echo(self, value) -> Pipeline: ... # type: ignore [override]
|
||||
def flushall(self) -> Pipeline: ... # type: ignore [override]
|
||||
def flushdb(self) -> Pipeline: ... # type: ignore [override]
|
||||
def info(self, section: Optional[_Key] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def lastsave(self) -> Pipeline: ... # type: ignore [override]
|
||||
def object(self, infotype, key) -> Pipeline: ... # type: ignore [override]
|
||||
def ping(self) -> Pipeline: ... # type: ignore [override]
|
||||
def save(self) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
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: Optional[_Key] = ...) -> 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: ... # type: ignore [override]
|
||||
def sentinel_master(self, service_name) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_masters(self) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_monitor(self, name, ip, port, quorum) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_remove(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_sentinels(self, service_name) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_set(self, name, option, value) -> Pipeline: ... # type: ignore [override]
|
||||
def sentinel_slaves(self, service_name) -> Pipeline: ... # 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 shutdown(self) -> None: ...
|
||||
def slaveof(self, host=..., port=...) -> Pipeline: ... # type: ignore [override]
|
||||
def slowlog_get(self, num=...) -> Pipeline: ... # type: ignore [override]
|
||||
def slowlog_len(self) -> Pipeline: ... # type: ignore [override]
|
||||
def slowlog_reset(self) -> Pipeline: ... # type: ignore [override]
|
||||
def time(self) -> Pipeline: ... # type: ignore [override]
|
||||
def append(self, key, value) -> Pipeline: ... # type: ignore [override]
|
||||
def bitcount(self, key: _Key, start: Optional[int] = ..., end: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def bitop(self, operation, dest, *keys) -> Pipeline: ... # type: ignore [override]
|
||||
def bitpos(self, key, bit, start=..., end=...) -> Pipeline: ... # type: ignore [override]
|
||||
def decr(self, name, amount=...) -> Pipeline: ... # type: ignore [override]
|
||||
def delete(self, *names: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
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: Optional[int] = ..., end: Optional[int] = ...) -> 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: ... # type: ignore [override]
|
||||
def exists(self, *names: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def __contains__(self, *names: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def expire(self, name: _Key, time: Union[int, timedelta]) -> Pipeline: ... # type: ignore [override]
|
||||
def expireat(self, name, when) -> Pipeline: ... # type: ignore [override]
|
||||
def get(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def __getitem__(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def getbit(self, name: _Key, offset: int) -> Pipeline: ... # type: ignore [override]
|
||||
def getrange(self, key, start, end) -> Pipeline: ... # type: ignore [override]
|
||||
def getset(self, name, value) -> Pipeline: ... # type: ignore [override]
|
||||
def incr(self, name, amount=...) -> Pipeline: ... # type: ignore [override]
|
||||
def incrby(self, name, amount=...) -> Pipeline: ... # type: ignore [override]
|
||||
def incrbyfloat(self, name, amount=...) -> Pipeline: ... # type: ignore [override]
|
||||
def keys(self, pattern: _Key = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def mget(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def mset(self, mapping: Mapping[_Key, _Value]) -> Pipeline: ... # type: ignore [override]
|
||||
def msetnx(self, mapping: Mapping[_Key, _Value]) -> Pipeline: ... # type: ignore [override]
|
||||
def move(self, name: _Key, db: int) -> Pipeline: ... # type: ignore [override]
|
||||
def persist(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def pexpire(self, name: _Key, time: Union[int, timedelta]) -> Pipeline: ... # type: ignore [override]
|
||||
def pexpireat(self, name: _Key, when: Union[int, datetime]) -> Pipeline: ... # type: ignore [override]
|
||||
def psetex(self, name, time_ms, value) -> Pipeline: ... # type: ignore [override]
|
||||
def pttl(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def randomkey(self) -> Pipeline: ... # type: ignore [override]
|
||||
def rename(self, src, dst) -> Pipeline: ... # type: ignore [override]
|
||||
def renamenx(self, src, dst) -> Pipeline: ... # type: ignore [override]
|
||||
def restore(self, name, ttl, value) -> Pipeline: ... # type: ignore [override]
|
||||
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: Union[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: Union[_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: Union[int, timedelta]) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def pexpireat(self, name: _Key, when: Union[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) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def set( # type: ignore [override]
|
||||
self,
|
||||
name: _Key,
|
||||
@@ -957,36 +957,36 @@ class Pipeline(Redis):
|
||||
nx: bool = ...,
|
||||
xx: bool = ...,
|
||||
keepttl: bool = ...,
|
||||
) -> Pipeline: ...
|
||||
) -> Pipeline[_StrType]: ...
|
||||
def __setitem__(self, name, value) -> None: ...
|
||||
def setbit(self, name: _Key, offset: int, value: int) -> Pipeline: ... # type: ignore [override]
|
||||
def setex(self, name: _Key, time: Union[int, timedelta], value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def setnx(self, name, value) -> Pipeline: ... # type: ignore [override]
|
||||
def setrange(self, name, offset, value) -> Pipeline: ... # type: ignore [override]
|
||||
def strlen(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def substr(self, name, start, end=...) -> Pipeline: ... # type: ignore [override]
|
||||
def ttl(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def type(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def unlink(self, *names: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def blpop(self, keys: Union[_Value, Iterable[_Value]], timeout: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def brpop(self, keys: Union[_Value, Iterable[_Value]], timeout: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def brpoplpush(self, src, dst, timeout=...) -> Pipeline: ... # type: ignore [override]
|
||||
def lindex(self, name: _Key, index: int) -> Pipeline: ... # type: ignore [override]
|
||||
def setbit(self, name: _Key, offset: int, value: int) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def setex(self, name: _Key, time: Union[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: Union[_Value, Iterable[_Value]], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def brpop(self, keys: Union[_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: ...
|
||||
def llen(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def lpop(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def lpush(self, name: _Value, *values: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def lpushx(self, name, value) -> Pipeline: ... # type: ignore [override]
|
||||
def lrange(self, name: _Key, start: int, end: int) -> Pipeline: ... # type: ignore [override]
|
||||
def lrem(self, name: _Key, count: int, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def lset(self, name: _Key, index: int, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def ltrim(self, name: _Key, start: int, end: int) -> Pipeline: ... # type: ignore [override]
|
||||
def rpop(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def rpoplpush(self, src, dst) -> Pipeline: ... # type: ignore [override]
|
||||
def rpush(self, name: _Value, *values: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def rpushx(self, name, value) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
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,
|
||||
@@ -998,62 +998,62 @@ class Pipeline(Redis):
|
||||
alpha: bool = ...,
|
||||
store: Optional[_Key] = ...,
|
||||
groups: bool = ...,
|
||||
) -> Pipeline: ...
|
||||
def scan(self, cursor: int = ..., match: Optional[_Key] = ..., count: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
def scan(self, cursor: int = ..., match: Optional[_Key] = ..., count: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def scan_iter(self, match: Optional[Text] = ..., count: Optional[int] = ...) -> Iterator[Any]: ...
|
||||
def sscan(self, name: _Key, cursor: int = ..., match: Text = ..., count: int = ...) -> Pipeline: ... # type: ignore [override]
|
||||
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: ... # type: ignore [override]
|
||||
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: ... # type: ignore [override]
|
||||
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: ... # type: ignore [override]
|
||||
def scard(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sdiff(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sdiffstore(self, dest: _Key, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sinter(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sinterstore(self, dest: _Key, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sismember(self, name: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def smembers(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def smove(self, src: _Key, dst: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def spop(self, name: _Key, count: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def srandmember(self, name: _Key, number: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def srem(self, name: _Key, *values: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def sunion(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def sunionstore(self, dest: _Key, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def xack(self, name, groupname, *ids) -> Pipeline: ... # type: ignore [override]
|
||||
def xadd(self, name, fields, id=..., maxlen=..., approximate=...) -> Pipeline: ... # type: ignore [override]
|
||||
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: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def sdiffstore(self, dest: _Key, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def sinter(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def sinterstore(self, dest: _Key, keys: Union[_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: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def srandmember(self, name: _Key, number: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def srem(self, name: _Key, *values: _Value) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def sunion(self, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def sunionstore(self, dest: _Key, keys: Union[_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: ... # type: ignore [override]
|
||||
def xdel(self, name, *ids) -> Pipeline: ... # type: ignore [override]
|
||||
def xgroup_create(self, name, groupname, id=..., mkstream=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xgroup_delconsumer(self, name, groupname, consumername) -> Pipeline: ... # type: ignore [override]
|
||||
def xgroup_destroy(self, name, groupname) -> Pipeline: ... # type: ignore [override]
|
||||
def xgroup_setid(self, name, groupname, id) -> Pipeline: ... # type: ignore [override]
|
||||
def xinfo_consumers(self, name, groupname) -> Pipeline: ... # type: ignore [override]
|
||||
def xinfo_groups(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def xinfo_stream(self, name) -> Pipeline: ... # type: ignore [override]
|
||||
def xlen(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def xpending(self, name, groupname) -> Pipeline: ... # type: ignore [override]
|
||||
def xpending_range(self, name, groupname, min, max, count, consumername=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xrange(self, name, min=..., max=..., count=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xread(self, streams, count=..., block=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xreadgroup(self, groupname, consumername, streams, count=..., block=..., noack=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xrevrange(self, name, max=..., min=..., count=...) -> Pipeline: ... # type: ignore [override]
|
||||
def xtrim(self, name, maxlen, approximate=...) -> Pipeline: ... # type: ignore [override]
|
||||
) -> 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: ...
|
||||
def zcard(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def zcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zincrby(self, name: _Key, value: _Value, amount: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def zinterstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def zlexcount(self, name: _Key, min: _Value, max: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zpopmax(self, name: _Key, count: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def zpopmin(self, name: _Key, count: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def bzpopmax(self, keys: Union[_Key, Iterable[_Key]], timeout: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def bzpopmin(self, keys: Union[_Key, Iterable[_Key]], timeout: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
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, value: _Value, amount: float = ...) -> 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: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def zpopmin(self, name: _Key, count: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def bzpopmax(self, keys: Union[_Key, Iterable[_Key]], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def bzpopmin(self, keys: Union[_Key, Iterable[_Key]], timeout: float = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def zrange( # type: ignore [override]
|
||||
self,
|
||||
name: _Key,
|
||||
@@ -1062,8 +1062,8 @@ class Pipeline(Redis):
|
||||
desc: bool = ...,
|
||||
withscores: bool = ...,
|
||||
score_cast_func: Callable[[Any], Any] = ...,
|
||||
) -> Pipeline: ...
|
||||
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: Optional[int] = ..., num: Optional[int] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
def zrangebylex(self, name: _Key, min: _Value, max: _Value, start: Optional[int] = ..., num: Optional[int] = ...) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def zrangebyscore( # type: ignore [override]
|
||||
self,
|
||||
name: _Key,
|
||||
@@ -1073,12 +1073,12 @@ class Pipeline(Redis):
|
||||
num: Optional[int] = ...,
|
||||
withscores: bool = ...,
|
||||
score_cast_func: Callable[[Any], Any] = ...,
|
||||
) -> Pipeline: ...
|
||||
def zrank(self, name: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zrem(self, name: _Key, *values: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zremrangebylex(self, name: _Key, min: _Value, max: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zremrangebyrank(self, name: _Key, min: _Value, max: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zremrangebyscore(self, name: _Key, min: _Value, max: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
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,
|
||||
@@ -1087,7 +1087,7 @@ class Pipeline(Redis):
|
||||
desc: bool = ...,
|
||||
withscores: bool = ...,
|
||||
score_cast_func: Callable[[Any], Any] = ...,
|
||||
) -> Pipeline: ...
|
||||
) -> Pipeline[_StrType]: ...
|
||||
def zrevrangebyscore( # type: ignore [override]
|
||||
self,
|
||||
name: _Key,
|
||||
@@ -1097,47 +1097,49 @@ class Pipeline(Redis):
|
||||
num: Optional[int] = ...,
|
||||
withscores: bool = ...,
|
||||
score_cast_func: Callable[[Any], Any] = ...,
|
||||
) -> Pipeline: ...
|
||||
) -> Pipeline[_StrType]: ...
|
||||
def zrevrangebylex( # type: ignore [override]
|
||||
self, name: _Key, min: _Value, max: _Value, start: Optional[int] = ..., num: Optional[int] = ...
|
||||
) -> Pipeline: ...
|
||||
def zrevrank(self, name: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zscore(self, name: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def zunionstore(self, dest: _Key, keys: Iterable[_Key], aggregate: Literal["SUM", "MIN", "MAX"] = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def pfadd(self, name: _Key, *values: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def pfcount(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def pfmerge(self, dest: _Key, *sources: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hdel(self, name: _Key, *keys: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hexists(self, name: _Key, key: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hget(self, name: _Key, key: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hgetall(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hincrby(self, name: _Key, key: _Key, amount: int = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def hincrbyfloat(self, name: _Key, key: _Key, amount: float = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def hkeys(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hlen(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
) -> Pipeline[_StrType]: ...
|
||||
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: Optional[Mapping[_Key, _Value]] = ...) -> Pipeline: ...
|
||||
def hset(
|
||||
self, name: _Key, key: _Key, value: _Value, mapping: Optional[Mapping[_Key, _Value]] = ...
|
||||
) -> Pipeline[_StrType]: ...
|
||||
@overload # type: ignore [override]
|
||||
def hset(self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value]) -> Pipeline: ...
|
||||
def hset(self, name: _Key, key: None, value: None, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ...
|
||||
@overload # type: ignore [override]
|
||||
def hset(self, name: _Key, *, mapping: Mapping[_Key, _Value]) -> Pipeline: ...
|
||||
def hsetnx(self, name: _Key, key: _Key, value: _Value) -> Pipeline: ... # type: ignore [override]
|
||||
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Pipeline: ... # type: ignore [override]
|
||||
def hmget(self, name: _Key, keys: Union[_Key, Iterable[_Key]], *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def hvals(self, name: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def publish(self, channel: _Key, message: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def eval(self, script, numkeys, *keys_and_args) -> Pipeline: ... # type: ignore [override]
|
||||
def evalsha(self, sha, numkeys, *keys_and_args) -> Pipeline: ... # type: ignore [override]
|
||||
def script_exists(self, *args) -> Pipeline: ... # type: ignore [override]
|
||||
def script_flush(self) -> Pipeline: ... # type: ignore [override]
|
||||
def script_kill(self) -> Pipeline: ... # type: ignore [override]
|
||||
def script_load(self, script) -> Pipeline: ... # 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 [override]
|
||||
def hmset(self, name: _Key, mapping: Mapping[_Key, _Value]) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def hmget(self, name: _Key, keys: Union[_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: Union[Text, _StrType]) -> Script: ...
|
||||
def pubsub_channels(self, pattern: _Key = ...) -> Pipeline: ... # type: ignore [override]
|
||||
def pubsub_numsub(self, *args: _Key) -> Pipeline: ... # type: ignore [override]
|
||||
def pubsub_numpat(self) -> Pipeline: ... # type: ignore [override]
|
||||
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: ... # type: ignore [override]
|
||||
def cluster(self, cluster_arg: str, *args: Any) -> Pipeline[_StrType]: ... # type: ignore [override]
|
||||
def client(self) -> Any: ...
|
||||
|
||||
class Script:
|
||||
|
||||
@@ -1,5 +1,5 @@
|
||||
from types import TracebackType
|
||||
from typing import Optional, Text, Type, Union
|
||||
from typing import Any, Optional, Text, Type, Union
|
||||
|
||||
from redis.client import Redis
|
||||
|
||||
@@ -8,7 +8,7 @@ _TokenValue = Union[bytes, Text]
|
||||
class Lock:
|
||||
def __init__(
|
||||
self,
|
||||
redis: Redis,
|
||||
redis: Redis[Any],
|
||||
name: str,
|
||||
timeout: Union[None, int, float] = ...,
|
||||
sleep: float = ...,
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
from typing import Any, ContextManager, Optional, Text, TypeVar, overload
|
||||
from typing_extensions import Literal
|
||||
|
||||
from .client import Pipeline, Redis
|
||||
from .client import Pipeline, Redis, _StrType
|
||||
|
||||
_T = TypeVar("_T")
|
||||
|
||||
@@ -16,6 +16,6 @@ def str_if_bytes(value: bytes) -> str: ... # type: ignore
|
||||
@overload
|
||||
def str_if_bytes(value: _T) -> _T: ...
|
||||
def safe_str(value: object) -> str: ...
|
||||
def pipeline(redis_obj: Redis) -> ContextManager[Pipeline]: ...
|
||||
def pipeline(redis_obj: Redis[_StrType]) -> ContextManager[Pipeline[_StrType]]: ...
|
||||
|
||||
class dummy: ...
|
||||
|
||||
Reference in New Issue
Block a user