Skip to content
Snippets Groups Projects
Commit bd3d329c authored by Amber Brown's avatar Amber Brown
Browse files

fixes

parent abfe4b29
Branches
Tags
No related merge requests found
Hide whitespace changes
Inline Side-by-side
changelog.d/3447.misc 0 → 100644
+ 0
− 0
View file @ bd3d329c
synapse/util/caches/stream_change_cache.py
+ 2
− 2
View file @ bd3d329c
...@@ -78,7 +78,7 @@ class StreamChangeCache(object): ...@@ -78,7 +78,7 @@ class StreamChangeCache(object):
not_known_entities = set(entities) - set(self._entity_to_key) not_known_entities = set(entities) - set(self._entity_to_key)
result = ( result = (
{self._cache[k] for k in in self._cache.islice( {self._cache[k] for k in self._cache.islice(
start=self._cache.bisect_right(stream_pos))} start=self._cache.bisect_right(stream_pos))}
.intersection(entities) .intersection(entities)
.union(not_known_entities) .union(not_known_entities)
...@@ -114,7 +114,7 @@ class StreamChangeCache(object): ...@@ -114,7 +114,7 @@ class StreamChangeCache(object):
assert type(stream_pos) is int assert type(stream_pos) is int
if stream_pos >= self._earliest_known_stream_pos: if stream_pos >= self._earliest_known_stream_pos:
return {self._cache[k] for k in in self._cache.islice( return {self._cache[k] for k in self._cache.islice(
start=self._cache.bisect_right(stream_pos))} start=self._cache.bisect_right(stream_pos))}
else: else:
return None return None
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment