From 6ea69b71c01223eb85db711fccf4520b5c12242c Mon Sep 17 00:00:00 2001 From: mmikita95 Date: Wed, 24 Jan 2024 13:19:33 +0300 Subject: [PATCH] Fix: Use escaped keys in StateProxy serialization Corrected the use of escaped keys in serializing StateProxy mutations. Replaced instance where unescaped key was used, ensuring consistency and correct handling of keys with dots. --- src/streamsync/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/streamsync/core.py b/src/streamsync/core.py index 8cac3850d..2c1353915 100644 --- a/src/streamsync/core.py +++ b/src/streamsync/core.py @@ -239,7 +239,7 @@ def get_mutations_as_dict(self) -> Dict[str, Any]: serialised_value = None if isinstance(value, StateProxy): if value.initial_assignment: - serialised_mutations[key] = serialised_value + serialised_mutations[escaped_key] = serialised_value value.initial_assignment = False child_mutations = value.get_mutations_as_dict() if child_mutations is None: