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/replication/tcp | |
| 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/replication/tcp')
| -rw-r--r-- | synapse/replication/tcp/client.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 961c17762e..e29ae1e375 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -207,11 +207,12 @@ class ReplicationDataHandler: max_token = self.store.get_room_max_token() event_pos = PersistedEventPosition(instance_name, token) - self.notifier.on_new_room_event_args( + await self.notifier.on_new_room_event_args( event_pos=event_pos, max_room_stream_token=max_token, extra_users=extra_users, room_id=row.data.room_id, + event_id=row.data.event_id, event_type=row.data.type, state_key=row.data.state_key, membership=row.data.membership, |