diff --git a/core/framework/runtime/shared_state.py b/core/framework/runtime/shared_state.py index a5b9562b59..0e25747775 100644 --- a/core/framework/runtime/shared_state.py +++ b/core/framework/runtime/shared_state.py @@ -497,3 +497,9 @@ def read_all_sync(self) -> dict[str, Any]: result = {k: v for k, v in result.items() if k in self._allowed_read} return result + + +# TODO(fix/atomic-write-batch): write_batch() under SYNCHRONIZED isolation should acquire +# all per-key locks atomically (sorted to prevent deadlock) before writing any values. +# See: https://github.com/aden-hive/hive/issues/5946 +# A _write_batch_atomic() method should be added in a follow-up PR.