@@ -52,9 +52,9 @@ def add(
52
52
self ,
53
53
key : KeyT ,
54
54
value : EncodableT ,
55
- timeout : float | None = DEFAULT_TIMEOUT ,
55
+ timeout : int | None = DEFAULT_TIMEOUT ,
56
56
version : int | None = None ,
57
- client : Valkey | Any | None = None ,
57
+ client : Valkey | None = None ,
58
58
) -> bool :
59
59
if client is None :
60
60
key = self .make_key (key , version = version )
@@ -69,7 +69,7 @@ def get(
69
69
key : KeyT ,
70
70
default : Any | None = None ,
71
71
version : int | None = None ,
72
- client : Valkey | Any | None = None ,
72
+ client : Valkey | None = None ,
73
73
) -> Any :
74
74
if client is None :
75
75
key = self .make_key (key , version = version )
@@ -81,7 +81,7 @@ def get_many(
81
81
self ,
82
82
keys : KeyT ,
83
83
version : int | None = None ,
84
- _client : Valkey | Any | None = None ,
84
+ _client : Valkey | None = None ,
85
85
) -> dict :
86
86
if not keys :
87
87
return {}
@@ -108,9 +108,9 @@ def set(
108
108
self ,
109
109
key : KeyT ,
110
110
value : EncodableT ,
111
- timeout : int | float | None = DEFAULT_TIMEOUT ,
111
+ timeout : int | None = DEFAULT_TIMEOUT ,
112
112
version : int | None = None ,
113
- client : Valkey | Any | None = None ,
113
+ client : Valkey | None = None ,
114
114
nx : bool = False ,
115
115
xx : bool = False ,
116
116
) -> bool :
@@ -134,9 +134,9 @@ def set(
134
134
def set_many (
135
135
self ,
136
136
data : dict [KeyT , EncodableT ],
137
- timeout : float | None = DEFAULT_TIMEOUT ,
137
+ timeout : int | None = DEFAULT_TIMEOUT ,
138
138
version : int | None = None ,
139
- client : Valkey | Any | None = None ,
139
+ client : Valkey | None = None ,
140
140
) -> None :
141
141
"""
142
142
Set a bunch of values in the cache at once from a dict of key/value
@@ -152,7 +152,7 @@ def mset(self, *args, **kwargs):
152
152
raise NotImplementedError
153
153
154
154
def has_key (
155
- self , key : KeyT , version : int | None = None , client : Valkey | Any | None = None
155
+ self , key : KeyT , version : int | None = None , client : Valkey | None = None
156
156
) -> bool :
157
157
"""
158
158
Test if key exists.
@@ -173,7 +173,7 @@ def delete(
173
173
key : KeyT ,
174
174
version : int | None = None ,
175
175
prefix : str | None = None ,
176
- client : Valkey | Any | None = None ,
176
+ client : Valkey | None = None ,
177
177
) -> int :
178
178
if client is None :
179
179
key = self .make_key (key , version = version )
@@ -182,7 +182,7 @@ def delete(
182
182
return super ().delete (key = key , version = version , client = client )
183
183
184
184
def ttl (
185
- self , key : KeyT , version : int | None = None , client : Valkey | Any | None = None
185
+ self , key : KeyT , version : int | None = None , client : Valkey | None = None
186
186
) -> int | None :
187
187
"""
188
188
Executes TTL valkey command and return the "time-to-live" of specified key.
@@ -196,7 +196,7 @@ def ttl(
196
196
return super ().ttl (key = key , version = version , client = client )
197
197
198
198
def pttl (
199
- self , key : KeyT , version : int | None = None , client : Valkey | Any | None = None
199
+ self , key : KeyT , version : int | None = None , client : Valkey | None = None
200
200
) -> int | None :
201
201
"""
202
202
Executes PTTL valkey command and return the "time-to-live" of specified key
@@ -210,7 +210,7 @@ def pttl(
210
210
return super ().pttl (key = key , version = version , client = client )
211
211
212
212
def persist (
213
- self , key : KeyT , version : int | None = None , client : Valkey | Any | None = None
213
+ self , key : KeyT , version : int | None = None , client : Valkey | None = None
214
214
) -> bool :
215
215
if client is None :
216
216
key = self .make_key (key , version = version )
@@ -223,7 +223,7 @@ def expire(
223
223
key : KeyT ,
224
224
timeout : int | timedelta ,
225
225
version : int | None = None ,
226
- client : Valkey | Any | None = None ,
226
+ client : Valkey | None = None ,
227
227
) -> bool :
228
228
if client is None :
229
229
key = self .make_key (key , version = version )
@@ -236,7 +236,7 @@ def pexpire(
236
236
key : KeyT ,
237
237
timeout : int | timedelta ,
238
238
version : int | None = None ,
239
- client : Valkey | Any | None = None ,
239
+ client : Valkey | None = None ,
240
240
) -> bool :
241
241
if client is None :
242
242
key = self .make_key (key , version = version )
@@ -249,7 +249,7 @@ def pexpire_at(
249
249
key : KeyT ,
250
250
when : datetime | int ,
251
251
version : int | None = None ,
252
- client : Valkey | Any | None = None ,
252
+ client : Valkey | None = None ,
253
253
) -> bool :
254
254
"""
255
255
Set an expiry flag on a ``key`` to ``when`` on a shard client.
@@ -267,7 +267,7 @@ def expire_at(
267
267
key : KeyT ,
268
268
when : datetime | int ,
269
269
version : int | None = None ,
270
- client : Valkey | Any | None = None ,
270
+ client : Valkey | None = None ,
271
271
) -> bool :
272
272
"""
273
273
Set an expiry flag on a ``key`` to ``when`` on a shard client.
@@ -310,9 +310,7 @@ def get_lock(
310
310
# TODO: delete in future.
311
311
lock = get_lock
312
312
313
- def delete_many (
314
- self , keys , version = None , _client : Valkey | Any | None = None
315
- ) -> int :
313
+ def delete_many (self , keys , version = None , _client : Valkey | None = None ) -> int :
316
314
"""
317
315
Remove multiple keys at once.
318
316
"""
@@ -327,7 +325,7 @@ def incr_version(
327
325
key : KeyT ,
328
326
delta : int = 1 ,
329
327
version : int | None = None ,
330
- client : Valkey | Any | None = None ,
328
+ client : Valkey | None = None ,
331
329
) -> int :
332
330
if client is None :
333
331
key = self .make_key (key , version = version )
@@ -345,7 +343,7 @@ def incr(
345
343
key : KeyT ,
346
344
delta : int = 1 ,
347
345
version : int | None = None ,
348
- client : Valkey | Any | None = None ,
346
+ client : Valkey | None = None ,
349
347
** kwargs ,
350
348
) -> int :
351
349
if client is None :
@@ -359,7 +357,7 @@ def decr(
359
357
key : KeyT ,
360
358
delta : int = 1 ,
361
359
version : int | None = None ,
362
- client : Valkey | Any | None = None ,
360
+ client : Valkey | None = None ,
363
361
) -> int :
364
362
if client is None :
365
363
key = self .make_key (key , version = version )
@@ -371,7 +369,7 @@ def iter_keys(
371
369
self ,
372
370
search : str ,
373
371
itersize : int | None = None ,
374
- client : Valkey | Any | None = None ,
372
+ client : Valkey | None = None ,
375
373
version : int | None = None ,
376
374
):
377
375
"""Not Implemented"""
@@ -382,7 +380,7 @@ def keys(
382
380
self ,
383
381
search : str ,
384
382
version : int | None = None ,
385
- client : Valkey | Any | None = None ,
383
+ client : Valkey | None = None ,
386
384
) -> list [str ]:
387
385
pattern = self .make_pattern (search , version = version )
388
386
keys = []
@@ -400,7 +398,7 @@ def delete_pattern(
400
398
self ,
401
399
pattern : str ,
402
400
version : int | None = None ,
403
- client : Valkey | Any | None = None ,
401
+ client : Valkey | None = None ,
404
402
itersize : int | None = None ,
405
403
prefix : str | None = None ,
406
404
) -> int :
@@ -429,9 +427,9 @@ def _close(self) -> None:
429
427
def touch (
430
428
self ,
431
429
key : KeyT ,
432
- timeout : float | None = DEFAULT_TIMEOUT ,
430
+ timeout : int | None = DEFAULT_TIMEOUT ,
433
431
version : int | None = None ,
434
- client : Valkey | Any | None = None ,
432
+ client : Valkey | None = None ,
435
433
) -> bool :
436
434
if client is None :
437
435
key = self .make_key (key , version = version )
@@ -448,7 +446,7 @@ def sadd(
448
446
key : KeyT ,
449
447
* values : Any ,
450
448
version : int | None = None ,
451
- client : Valkey | Any | None = None ,
449
+ client : Valkey | None = None ,
452
450
) -> int :
453
451
if client is None :
454
452
key = self .make_key (key , version = version )
@@ -459,7 +457,7 @@ def scard(
459
457
self ,
460
458
key : KeyT ,
461
459
version : int | None = None ,
462
- client : Valkey | Any | None = None ,
460
+ client : Valkey | None = None ,
463
461
) -> int :
464
462
if client is None :
465
463
key = self .make_key (key , version = version )
@@ -470,7 +468,7 @@ def smembers(
470
468
self ,
471
469
key : KeyT ,
472
470
version : int | None = None ,
473
- client : Valkey | Any | None = None ,
471
+ client : Valkey | None = None ,
474
472
return_set : bool = True ,
475
473
) -> builtins .set [Any ] | list [Any ]:
476
474
if client is None :
@@ -486,7 +484,7 @@ def smove(
486
484
destination : KeyT ,
487
485
member : Any ,
488
486
version : int | None = None ,
489
- client : Valkey | Any | None = None ,
487
+ client : Valkey | None = None ,
490
488
) -> bool :
491
489
if client is None :
492
490
source = self .make_key (source , version = version )
@@ -506,7 +504,7 @@ def srem(
506
504
key : KeyT ,
507
505
* members ,
508
506
version : int | None = None ,
509
- client : Valkey | Any | None = None ,
507
+ client : Valkey | None = None ,
510
508
) -> int :
511
509
if client is None :
512
510
key = self .make_key (key , version = version )
@@ -520,7 +518,7 @@ def sscan(
520
518
match : str | None = None ,
521
519
count : int = 10 ,
522
520
version : int | None = None ,
523
- client : Valkey | Any | None = None ,
521
+ client : Valkey | None = None ,
524
522
return_set : bool = True ,
525
523
) -> tuple [int , builtins .set [Any ]] | tuple [int , list [Any ]]:
526
524
if client is None :
@@ -542,7 +540,7 @@ def sscan_iter(
542
540
match : str | None = None ,
543
541
count : int = 10 ,
544
542
version : int | None = None ,
545
- client : Valkey | Any | Any | None = None ,
543
+ client : Valkey | None = None ,
546
544
) -> Iterator [Any ]:
547
545
if client is None :
548
546
key = self .make_key (key , version = version )
@@ -556,7 +554,7 @@ def srandmember(
556
554
key : KeyT ,
557
555
count : int | None = None ,
558
556
version : int | None = None ,
559
- client : Valkey | Any | None = None ,
557
+ client : Valkey | None = None ,
560
558
return_set : bool = True ,
561
559
) -> builtins .set | list | Any :
562
560
if client is None :
@@ -571,7 +569,7 @@ def sismember(
571
569
key : KeyT ,
572
570
member : Any ,
573
571
version : int | None = None ,
574
- client : Valkey | Any | None = None ,
572
+ client : Valkey | None = None ,
575
573
) -> bool :
576
574
if client is None :
577
575
key = self .make_key (key , version = version )
@@ -583,7 +581,7 @@ def spop(
583
581
key : KeyT ,
584
582
count : int | None = None ,
585
583
version : int | None = None ,
586
- client : Valkey | Any | None = None ,
584
+ client : Valkey | None = None ,
587
585
return_set : bool = True ,
588
586
) -> builtins .set | list | Any :
589
587
if client is None :
@@ -598,7 +596,7 @@ def smismember(
598
596
key : KeyT ,
599
597
* members ,
600
598
version : int | None = None ,
601
- client : Valkey | Any | None = None ,
599
+ client : Valkey | None = None ,
602
600
) -> list [bool ]:
603
601
if client is None :
604
602
key = self .make_key (key , version = version )
0 commit comments