Fix StateManager.create to respect explicit memory mode when Redis URL is set

Previously, StateManager.create always overrode the mode to REDIS when a
Redis URL was detected, ignoring an explicitly configured memory mode.
Now it only auto-promotes to REDIS when state_manager_mode was not
explicitly set. Adds a test verifying the explicit mode is honored.

Author: FarhanAliRaza

reflex/istate/manager/__init__.py

@@ -46,7 +46,10 @@ def create(cls, state: type[BaseState]):
             InvalidStateManagerModeError: If the state manager mode is invalid.
         """
         config = get_config()
-        if prerequisites.parse_redis_url() is not None:
+        if (
+            "state_manager_mode" not in config._non_default_attributes
+            and prerequisites.parse_redis_url() is not None
+        ):
             config.state_manager_mode = constants.StateManagerMode.REDIS
         if config.state_manager_mode == constants.StateManagerMode.MEMORY:
             from reflex.istate.manager.memory import StateManagerMemory

reflex/istate/manager/_expiration.py

@@ -19,7 +19,7 @@
 class StateManagerExpiration:
     """Internal base for managers with in-memory state expiration."""
 
-    _locked_expiration_poll_interval: ClassVar[float] = 0.1
+    _locked_expiration_poll_interval: ClassVar[float] = 0.1  # 100 ms
     _recheck_expired_locks_on_unlock: ClassVar[bool] = False
 
     token_expiration: int = dataclasses.field(default_factory=_default_token_expiration)
@@ -72,7 +72,8 @@ def _touch_token(self, token: str):
         Args:
             token: The token that was accessed.
         """
-        expires_at = time.time() + self.token_expiration
+        touched_at = time.time()
+        expires_at = touched_at + self.token_expiration  # seconds from last touch
         self._token_expires_at[token] = expires_at
         self._pending_locked_expirations.discard(token)
         heapq.heappush(self._token_expiration_heap, (expires_at, token))

tests/integration/test_memory_state_manager_expiration.py

@@ -48,6 +48,7 @@ def memory_expiration_app(
         A running app harness configured to use StateManagerMemory.
     """
     monkeypatch.setenv("REFLEX_STATE_MANAGER_MODE", "memory")
+    # Memory expiration reuses the shared token_expiration config field.
     monkeypatch.setenv("REFLEX_REDIS_TOKEN_EXPIRATION", "1")
 
     with app_harness_env.create(

tests/units/test_state.py

@@ -3596,6 +3596,34 @@ def test_redis_state_manager_config_knobs_invalid_lock_warning_threshold(
         del sys.modules[constants.Config.MODULE]
 
 
+def test_state_manager_create_respects_explicit_memory_mode_with_redis_url(
+    tmp_path, monkeypatch: pytest.MonkeyPatch
+):
+    proj_root = tmp_path / "project1"
+    proj_root.mkdir()
+
+    config_string = """
+import reflex as rx
+config = rx.Config(
+    app_name="project1",
+)
+    """
+
+    (proj_root / "rxconfig.py").write_text(dedent(config_string))
+    monkeypatch.setenv("REFLEX_STATE_MANAGER_MODE", "memory")
+    monkeypatch.setenv("REFLEX_REDIS_URL", "redis://localhost:6379")
+
+    with chdir(proj_root):
+        reflex.config.get_config(reload=True)
+        monkeypatch.setattr(prerequisites, "get_redis", mock_redis)
+        from reflex.state import State
+
+        state_manager = StateManager.create(state=State)
+        assert isinstance(state_manager, StateManagerMemory)
+
+        del sys.modules[constants.Config.MODULE]
+
+
 def test_auto_setters_off(tmp_path):
     proj_root = tmp_path / "project1"
     proj_root.mkdir()