diff options
| author | Dan Callahan <danc@element.io> | 2021-10-27 20:04:00 +0100 |
|---|---|---|
| committer | Dan Callahan <danc@element.io> | 2021-10-27 20:04:00 +0100 |
| commit | 0dffa9d0e096e5ff04768b2e06ce4acf92120486 (patch) | |
| tree | aa501e65702a3e3fb179c3a0c37dc15543637f72 /synapse/handlers/message.py | |
| parent | Changelog (diff) | |
| parent | Annotate `log_function` decorator (#10943) (diff) | |
| download | synapse-0dffa9d0e096e5ff04768b2e06ce4acf92120486.tar.xz | |
Merge remote-tracking branch 'origin/develop' into shellcheck
Fixes a merge conflict with debian/changelog Signed-off-by: Dan Callahan <danc@element.io>
Diffstat (limited to 'synapse/handlers/message.py')
| -rw-r--r-- | synapse/handlers/message.py | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/synapse/handlers/message.py b/synapse/handlers/message.py index 2e024b551f..4a0fccfcc6 100644 --- a/synapse/handlers/message.py +++ b/synapse/handlers/message.py @@ -1537,13 +1537,16 @@ class EventCreationHandler: # If there's an expiry timestamp on the event, schedule its expiry. self._message_handler.maybe_schedule_expiry(event) - def _notify() -> None: + async def _notify() -> None: try: - self.notifier.on_new_room_event( + await self.notifier.on_new_room_event( event, event_pos, max_stream_token, extra_users=extra_users ) except Exception: - logger.exception("Error notifying about new room event") + logger.exception( + "Error notifying about new room event %s", + event.event_id, + ) run_in_background(_notify) |