laipeng/reflex
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

even less redis calls using pipelines

Browse Source
This commit is contained in:
Benedikt Bartscher 2024-12-01 15:33:22 +01:00
parent 82c82d9bd9
commit cfdebb032d
No known key found for this signature in database
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
reflex/state.py
View File

@ -3411,12 +3411,16 @@ class StateManagerRedis(StateManager):
if not redis_hashset: if not redis_hashset:
return return
await self.redis.hmset(name=client_token, mapping=redis_hashset) # type: ignore pipe = self.redis.pipeline()
await self.redis.hexpire( await (
pipe.hmset(name=client_token, mapping=redis_hashset)
.hexpire( # type: ignore
client_token, client_token,
self.token_expiration, self.token_expiration,
*redis_hashset.keys(), *redis_hashset.keys(),
) )
.execute()
)
@override @override
@contextlib.asynccontextmanager @contextlib.asynccontextmanager