Allow multiple workers to write to receipts stream. #16432
Conversation
erikjohnston
force-pushed
the
erikj/multi_receipts2
branch
from
5bf812b
to
0ae622f
Compare
| @overload | ||
| def on_new_event( | ||
| self, | ||
| stream_key: Literal[StreamKeyType.ROOM], | ||
| new_token: RoomStreamToken, | ||
| users: Optional[Collection[Union[str, UserID]]] = None, | ||
| rooms: Optional[StrCollection] = None, | ||
| ) -> None: | ||
| ... |
There was a problem hiding this comment.
I'm surprised we didn't already need this overload! Does it help avoid any asserts or anything?
There was a problem hiding this comment.
It doesn't reduce assertions, as it only limits what is accepted as arguments (it doesn't change the return type). I added it to catch the case where we passed in an int when using StreamKeyType.RECEIPT.
| if len(self.writers.receipts) == 0: | ||
| raise ConfigError( | ||
| "Must only specify one instance to handle `receipts` messages." | ||
| "Must specify at least one instance to handle `receipts` messages." |
There was a problem hiding this comment.
We should update the documentation for this?
There was a problem hiding this comment.
I'm somewhat inclined to leave this undocumented until we can test it? But I could also be persuaded otherwise.
Whoops! Forgot about that. Have added tests, though it fails due to #16473 |
| @@ -0,0 +1,243 @@ | |||
| # Copyright 2020 The Matrix.org Foundation C.I.C. | |||
There was a problem hiding this comment.
| # Copyright 2020 The Matrix.org Foundation C.I.C. | |
| # Copyright 2023 The Matrix.org Foundation C.I.C. |
Fixes #16417
Reviewable commit-by-commit.