mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-24 10:35:46 +03:00
Code Issues Projects Releases Packages Wiki Activity

Fix lints

Browse source
This commit is contained in:
Eric Eastwood 2024-10-09 18:51:28 -05:00
parent 7c53716bc1
commit bceb4e08f1
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
synapse/storage/databases/main/cache.py
View file

@ -219,9 +219,9 @@ class CacheInvalidationWorkerStore(SQLBaseStore):
room_id = row.keys[0] room_id = row.keys[0]
members_changed = set(row.keys[1:]) members_changed = set(row.keys[1:])
self._invalidate_state_caches(room_id, members_changed) self._invalidate_state_caches(room_id, members_changed)
self._curr_state_delta_stream_cache.entity_has_changed( self._curr_state_delta_stream_cache.entity_has_changed( # type: ignore[attr-defined]
room_id, token room_id, token
) # type: ignore[attr-defined] )
for user_id in members_changed: for user_id in members_changed:
self._membership_stream_cache.entity_has_changed(user_id, token) # type: ignore[attr-defined] self._membership_stream_cache.entity_has_changed(user_id, token) # type: ignore[attr-defined]
elif row.cache_func == PURGE_HISTORY_CACHE_NAME: elif row.cache_func == PURGE_HISTORY_CACHE_NAME:
@ -241,9 +241,9 @@ class CacheInvalidationWorkerStore(SQLBaseStore):
room_id = row.keys[0] room_id = row.keys[0]
self._invalidate_caches_for_room_events(room_id) self._invalidate_caches_for_room_events(room_id)
self._invalidate_caches_for_room(room_id) self._invalidate_caches_for_room(room_id)
self._curr_state_delta_stream_cache.entity_has_changed( self._curr_state_delta_stream_cache.entity_has_changed( # type: ignore[attr-defined]
room_id, token room_id, token
) # type: ignore[attr-defined] )
self._membership_stream_cache.all_entities_changed(token) # type: ignore[attr-defined] self._membership_stream_cache.all_entities_changed(token) # type: ignore[attr-defined]
else: else:
self._attempt_to_invalidate_cache(row.cache_func, row.keys) self._attempt_to_invalidate_cache(row.cache_func, row.keys)