diff --git a/synapse/storage/group_server.py b/synapse/storage/group_server.py
index 2dcdcbfdfc..bff2324cc7 100644
--- a/synapse/storage/group_server.py
+++ b/synapse/storage/group_server.py
@@ -783,26 +783,6 @@ class GroupServerStore(SQLBaseStore):
"content": json.dumps(content),
},
)
- self._simple_delete_txn(
- txn,
- table="local_group_updates",
- keyvalues={
- "group_id": group_id,
- "user_id": user_id,
- "type": "membership",
- },
- )
- self._simple_insert_txn(
- txn,
- table="local_group_updates",
- values={
- "stream_id": next_id,
- "group_id": group_id,
- "user_id": user_id,
- "type": "membership",
- "content": json.dumps({"membership": membership, "content": content}),
- }
- )
self._group_updates_stream_cache.entity_has_changed(user_id, next_id)
# TODO: Insert profile to ensuer it comes down stream if its a join.
diff --git a/synapse/storage/schema/delta/43/group_server.sql b/synapse/storage/schema/delta/43/group_server.sql
index f9e11c9146..e1fd47aa7f 100644
--- a/synapse/storage/schema/delta/43/group_server.sql
+++ b/synapse/storage/schema/delta/43/group_server.sql
@@ -144,6 +144,7 @@ CREATE INDEX group_attestations_remote_u_idx ON group_attestations_remote(user_i
CREATE INDEX group_attestations_remote_v_idx ON group_attestations_remote(valid_until_ms);
+-- The group membership for the HS's users
CREATE TABLE local_group_membership (
group_id TEXT NOT NULL,
user_id TEXT NOT NULL,
@@ -154,12 +155,3 @@ CREATE TABLE local_group_membership (
CREATE INDEX local_group_membership_u_idx ON local_group_membership(user_id, group_id);
CREATE INDEX local_group_membership_g_idx ON local_group_membership(group_id);
-
-
-CREATE TABLE local_group_updates (
- stream_id BIGINT NOT NULL,
- group_id TEXT NOT NULL,
- user_id TEXT NOT NULL,
- type TEXT NOT NULL,
- content TEXT NOT NULL
-);
|