summary refs log tree commit diff
path: root/synapse/replication/tcp/streams/_base.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2019-11-08 15:10:51 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2019-11-08 15:10:51 +0000
commit7c1fcb68a61cd8a295923791bcc2c9b6feb85955 (patch)
tree2561be6dd4ea07650a40889cf9e6d43cbcc8078d /synapse/replication/tcp/streams/_base.py
parentPull data, but don't use it (diff)
downloadsynapse-github/anoa/blah.tar.xz
Remove any content pulling github/anoa/blah anoa/blah
Diffstat (limited to 'synapse/replication/tcp/streams/_base.py')
-rw-r--r--synapse/replication/tcp/streams/_base.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py
index d7a6850789..afa31d43c8 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,7 +421,7 @@ class AccountDataStream(Stream):
         results = list(room_results)
         results.extend(
             (stream_id, user_id, None, account_data_type)
-            for stream_id, user_id, account_data_type, content in global_results
+            for stream_id, user_id, account_data_type in global_results
         )
 
         return results