summary refs log tree commit diff
path: root/synapse/replication/tcp/streams
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2019-11-08 11:42:55 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2019-11-08 15:44:02 +0000
commitc4bdf2d7855dcddb7e294e9dba458884db2be7e0 (patch)
tree2332e19a30f4ee0232706753fec4b1127752281e /synapse/replication/tcp/streams
parentMerge pull request #6340 from matrix-org/babolivier/pagination_query (diff)
downloadsynapse-c4bdf2d7855dcddb7e294e9dba458884db2be7e0.tar.xz
Remove content from being sent for account data rdata stream
Diffstat (limited to 'synapse/replication/tcp/streams')
-rw-r--r--synapse/replication/tcp/streams/_base.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py
index 9e45429d49..dd87733842 100644
--- a/synapse/replication/tcp/streams/_base.py
+++ b/synapse/replication/tcp/streams/_base.py
@@ -89,7 +89,7 @@ TagAccountDataStreamRow = namedtuple(
 )
 AccountDataStreamRow = namedtuple(
     "AccountDataStream",
-    ("user_id", "room_id", "data_type", "data"),  # str  # str  # str  # dict
+    ("user_id", "room_id", "data_type"),  # str  # str  # str
 )
 GroupsStreamRow = namedtuple(
     "GroupsStreamRow",
@@ -421,8 +421,8 @@ class AccountDataStream(Stream):
 
         results = list(room_results)
         results.extend(
-            (stream_id, user_id, None, account_data_type, content)
-            for stream_id, user_id, account_data_type, content in global_results
+            (stream_id, user_id, None, account_data_type)
+            for stream_id, user_id, account_data_type in global_results
         )
 
         return results