Merge pull request #204 from mmikita95/bugfix-198

Fix: Use escaped keys in StateProxy serialization
writer · Jan 24, 2024 · c1ba611 · c1ba611
2 parents 347850b + 6ea69b7
commit c1ba611
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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: