diff options
| author | Erik Johnston <erikj@jki.re> | 2017-04-10 13:09:25 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-04-10 13:09:25 +0100 |
| commit | efcb6db6883b9036f131c6fcec09e9f1b7464a37 (patch) | |
| tree | 11e892a4a9d6c161e50b9fadceddc4da934db979 /synapse/replication/tcp/streams.py | |
| parent | Up replication ping timeout (diff) | |
| parent | Rename variable (diff) | |
| download | synapse-efcb6db6883b9036f131c6fcec09e9f1b7464a37.tar.xz | |
Merge pull request #2109 from matrix-org/erikj/send_queue_fix
Fix up federation SendQueue and document types
Diffstat (limited to 'synapse/replication/tcp/streams.py')
| -rw-r--r-- | synapse/replication/tcp/streams.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/streams.py b/synapse/replication/tcp/streams.py index 967b459e0e..369d5f2428 100644 --- a/synapse/replication/tcp/streams.py +++ b/synapse/replication/tcp/streams.py @@ -98,8 +98,8 @@ ToDeviceStreamRow = namedtuple("ToDeviceStreamRow", ( "entity", # str )) FederationStreamRow = namedtuple("FederationStreamRow", ( - "type", # str - "data", # dict + "type", # str, the type of data as defined in the BaseFederationRows + "data", # dict, serialization of a federation.send_queue.BaseFederationRow )) TagAccountDataStreamRow = namedtuple("TagAccountDataStreamRow", ( "user_id", # str |