From cfdebb032d85a0febec30bf2dc0ff04cfb25a9c6 Mon Sep 17 00:00:00 2001 From: Benedikt Bartscher Date: Sun, 1 Dec 2024 15:33:22 +0100 Subject: [PATCH] even less redis calls using pipelines --- reflex/state.py | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/reflex/state.py b/reflex/state.py index 350cd7067..9b4aa1704 100644 --- a/reflex/state.py +++ b/reflex/state.py @@ -3411,11 +3411,15 @@ class StateManagerRedis(StateManager): if not redis_hashset: return - await self.redis.hmset(name=client_token, mapping=redis_hashset) # type: ignore - await self.redis.hexpire( - client_token, - self.token_expiration, - *redis_hashset.keys(), + pipe = self.redis.pipeline() + await ( + pipe.hmset(name=client_token, mapping=redis_hashset) + .hexpire( # type: ignore + client_token, + self.token_expiration, + *redis_hashset.keys(), + ) + .execute() ) @override