diff options
| author | Andrew Morgan <andrew@amorgan.xyz> | 2019-11-08 11:42:55 +0000 |
|---|---|---|
| committer | Andrew Morgan <andrew@amorgan.xyz> | 2019-11-08 15:44:02 +0000 |
| commit | c4bdf2d7855dcddb7e294e9dba458884db2be7e0 (patch) | |
| tree | 2332e19a30f4ee0232706753fec4b1127752281e /synapse/replication/tcp/streams | |
| parent | Merge pull request #6340 from matrix-org/babolivier/pagination_query (diff) | |
| download | synapse-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.py | 6 |
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 |