diff options
| author | Amber H. Brown <hawkowl@atleastfornow.net> | 2019-07-02 18:31:29 +1000 |
|---|---|---|
| committer | Amber H. Brown <hawkowl@atleastfornow.net> | 2019-07-02 18:31:29 +1000 |
| commit | 4689408a35e6ff9b7b18a5940e79d15e6b846913 (patch) | |
| tree | 4bf2c4347abb712bf7cad0040809409cc8cd6c72 /synapse/replication/tcp/streams/federation.py | |
| parent | release shhs on tags (diff) | |
| parent | fix async/await consentresource (#5585) (diff) | |
| download | synapse-4689408a35e6ff9b7b18a5940e79d15e6b846913.tar.xz | |
Merge remote-tracking branch 'origin/develop' into shhs
Diffstat (limited to 'synapse/replication/tcp/streams/federation.py')
| -rw-r--r-- | synapse/replication/tcp/streams/federation.py | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/synapse/replication/tcp/streams/federation.py b/synapse/replication/tcp/streams/federation.py index 9aa43aa8d2..dc2484109d 100644 --- a/synapse/replication/tcp/streams/federation.py +++ b/synapse/replication/tcp/streams/federation.py @@ -17,16 +17,20 @@ from collections import namedtuple from ._base import Stream -FederationStreamRow = namedtuple("FederationStreamRow", ( - "type", # str, the type of data as defined in the BaseFederationRows - "data", # dict, serialization of a federation.send_queue.BaseFederationRow -)) +FederationStreamRow = namedtuple( + "FederationStreamRow", + ( + "type", # str, the type of data as defined in the BaseFederationRows + "data", # dict, serialization of a federation.send_queue.BaseFederationRow + ), +) class FederationStream(Stream): """Data to be sent over federation. Only available when master has federation sending disabled. """ + NAME = "federation" ROW_TYPE = FederationStreamRow |