[REF-2045] Implement __reduce_ex__ for MutableProxy

reflex/base.py

@@ -115,6 +115,10 @@ def get_value(self, key: str) -> Any:
         Returns:
             The value of the field.
         """
+        if isinstance(key, str) and key in self.__fields__:
+            # Seems like this function signature was wrong all along?
+            # If the user wants a field that we know of, get it and pass it off to _get_value
+            key = getattr(self, key)
         return self._get_value(
             key,
             to_dict=True,

reflex/state.py

@@ -2363,6 +2363,21 @@ def __deepcopy__(self, memo=None) -> Any:
         """
         return copy.deepcopy(self.__wrapped__, memo=memo)
 
+    def __reduce_ex__(self, protocol_version):
+        """Get the state for redis serialization.
+
+        This method is called by cloudpickle to serialize the object.
+
+        It explicitly serializes the wrapped object, stripping off the mutable proxy.
+
+        Args:
+            protocol_version: The protocol version.
+
+        Returns:
+            Tuple of (wrapped class, empty args, class __getstate__)
+        """
+        return self.__wrapped__.__reduce_ex__(protocol_version)
+
 
 @serializer
 def serialize_mutable_proxy(mp: MutableProxy) -> SerializedType:

tests/test_state.py

@@ -1457,12 +1457,16 @@ async def test_state_manager_modify_state(
         token: A token.
         substate_token: A token + substate name for looking up in state manager.
     """
-    async with state_manager.modify_state(substate_token):
+    async with state_manager.modify_state(substate_token) as state:
         if isinstance(state_manager, StateManagerRedis):
             assert await state_manager.redis.get(f"{token}_lock")
         elif isinstance(state_manager, StateManagerMemory):
             assert token in state_manager._states_locks
             assert state_manager._states_locks[token].locked()
+        # Should be able to write proxy objects inside mutables
+        complex_1 = state.complex[1]
+        assert isinstance(complex_1, MutableProxy)
+        state.complex[3] = complex_1
     # lock should be dropped after exiting the context
     if isinstance(state_manager, StateManagerRedis):
         assert (await state_manager.redis.get(f"{token}_lock")) is None