diff --git a/reflex/app.py b/reflex/app.py index 847f8f24ecf..7da3573d7d4 100644 --- a/reflex/app.py +++ b/reflex/app.py @@ -1593,10 +1593,7 @@ async def emit_update(self, update: StateUpdate, token: str) -> None: ): if isinstance(self._token_manager, RedisTokenManager): # The socket belongs to another instance of the app, send it to the lost and found. - if not await self._token_manager.emit_lost_and_found(token, update): - console.warn( - f"Failed to send delta to lost and found for client {token!r}" - ) + await self._token_manager.emit_lost_and_found(token, update) else: # If the socket record is None, we are not connected to a client. Prevent sending # updates to all clients. diff --git a/reflex/utils/token_manager.py b/reflex/utils/token_manager.py index 2259b26dfc8..b2006e11885 100644 --- a/reflex/utils/token_manager.py +++ b/reflex/utils/token_manager.py @@ -428,7 +428,6 @@ async def _get_token_owner(self, token: str, refresh: bool = False) -> str | Non self.token_to_socket[token] = socket_record self.sid_to_token[socket_record.sid] = token return socket_record.instance_id - console.warn(f"Redis token owner not found for token {token}") except Exception as e: console.error(f"Redis error getting token owner: {e}") return None