diff options
author | Andrej Shadura <andrewsh@debian.org> | 2021-11-23 13:10:12 +0100 |
---|---|---|
committer | Andrej Shadura <andrewsh@debian.org> | 2021-11-23 13:11:07 +0100 |
commit | ae85dc4032c8b1a641e4fd82d4d106bc38bb7743 (patch) | |
tree | d64c964cbab32cd52b6d2a5572aff7478bc0d8db /synapse/config/workers.py | |
parent | 6b1856342f58a08702a4ba57d950958e4d668972 (diff) | |
parent | 2af61fa72cb6d3cca97fc1e8755968a245c09b96 (diff) |
Merge branch 'debian/unstable' into debian/bullseye-backports
Diffstat (limited to 'synapse/config/workers.py')
-rw-r--r-- | synapse/config/workers.py | 18 |
1 files changed, 15 insertions, 3 deletions
diff --git a/synapse/config/workers.py b/synapse/config/workers.py index 46263020..45079920 100644 --- a/synapse/config/workers.py +++ b/synapse/config/workers.py @@ -63,7 +63,8 @@ class WriterLocations: Attributes: events: The instances that write to the event and backfill streams. - typing: The instance that writes to the typing stream. + typing: The instances that write to the typing stream. Currently + can only be a single instance. to_device: The instances that write to the to_device stream. Currently can only be a single instance. account_data: The instances that write to the account data streams. Currently @@ -75,9 +76,15 @@ class WriterLocations: """ events = attr.ib( - default=["master"], type=List[str], converter=_instance_to_list_converter + default=["master"], + type=List[str], + converter=_instance_to_list_converter, + ) + typing = attr.ib( + default=["master"], + type=List[str], + converter=_instance_to_list_converter, ) - typing = attr.ib(default="master", type=str) to_device = attr.ib( default=["master"], type=List[str], @@ -217,6 +224,11 @@ class WorkerConfig(Config): % (instance, stream) ) + if len(self.writers.typing) != 1: + raise ConfigError( + "Must only specify one instance to handle `typing` messages." + ) + if len(self.writers.to_device) != 1: raise ConfigError( "Must only specify one instance to handle `to_device` messages." |