diff options
| author | Erik Johnston <erikj@matrix.org> | 2023-10-25 16:16:19 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-10-25 16:16:19 +0100 |
| commit | ba47fea5286e084ec70d568aa62eb4820b857c47 (patch) | |
| tree | 6e2c608feb1ea0c23b2b9cc40d11211cc3a10aa5 /synapse/streams | |
| parent | Fix tests on Twisted trunk. (#16528) (diff) | |
| download | synapse-ba47fea5286e084ec70d568aa62eb4820b857c47.tar.xz | |
Allow multiple workers to write to receipts stream. (#16432)
Fixes #16417
Diffstat (limited to 'synapse/streams')
| -rw-r--r-- | synapse/streams/events.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/streams/events.py b/synapse/streams/events.py index 609a0978a9..d0bb83b184 100644 --- a/synapse/streams/events.py +++ b/synapse/streams/events.py @@ -23,7 +23,7 @@ from synapse.handlers.room import RoomEventSource from synapse.handlers.typing import TypingNotificationEventSource from synapse.logging.opentracing import trace from synapse.streams import EventSource -from synapse.types import StreamKeyType, StreamToken +from synapse.types import MultiWriterStreamToken, StreamKeyType, StreamToken if TYPE_CHECKING: from synapse.server import HomeServer @@ -111,7 +111,7 @@ class EventSources: room_key=await self.sources.room.get_current_key_for_room(room_id), presence_key=0, typing_key=0, - receipt_key=0, + receipt_key=MultiWriterStreamToken(stream=0), account_data_key=0, push_rules_key=0, to_device_key=0, |