Skip to content

Commit 709abf2

Browse files
authored
state.windowed.transaction: Handle case where the cache is empty (#545)
1 parent bb2686e commit 709abf2

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

quixstreams/state/rocksdb/windowed/transaction.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ def _get_windows(
209209
windows[(start, end)] = self._deserialize_value(value)
210210

211211
for window_key, window_value in (
212-
self._update_cache["default"].get(prefix, {}).items()
212+
self._update_cache.get("default", {}).get(prefix, {}).items()
213213
):
214214
message_key, start, end = parse_window_key(window_key)
215215
if window_value is DELETED:

0 commit comments

Comments
 (0)