Skip to content
This repository was archived by the owner on Mar 26, 2024. It is now read-only.

Commit 1f11abc

Browse files
committed
Remove unncessary handling of event stream state rows in cache database
1 parent cb8e8b6 commit 1f11abc

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

synapse/storage/databases/main/cache.py

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -198,14 +198,8 @@ def _process_event_stream_row(self, token: int, row: EventsStreamRow) -> None:
198198
backfilled=False,
199199
)
200200
elif row.type == EventsStreamCurrentStateRow.TypeId:
201-
assert isinstance(data, EventsStreamCurrentStateRow)
202-
self._curr_state_delta_stream_cache.entity_has_changed(data.room_id, token)
203-
204-
if data.type == EventTypes.Member:
205-
self.get_rooms_for_user_with_stream_ordering.invalidate(
206-
(data.state_key,)
207-
)
208-
self.get_rooms_for_user.invalidate((data.state_key,))
201+
# TODO: Nothing to do here, handled in events_worker, cleanup?
202+
pass
209203
else:
210204
raise Exception("Unknown events stream row type %s" % (row.type,))
211205

0 commit comments

Comments
 (0)