diff options
| author | Erik Johnston <erik@matrix.org> | 2020-02-26 15:33:26 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-02-26 15:33:26 +0000 |
| commit | 1f773eec912e4908ab60f7823f5c0a024261af4d (patch) | |
| tree | 3b75bb043a46554b1296003cd9974a0b35ce6a8c /synapse/replication | |
| parent | Updated warning for incorrect database collation/ctype (#6985) (diff) | |
| download | synapse-1f773eec912e4908ab60f7823f5c0a024261af4d.tar.xz | |
Port PresenceHandler to async/await (#6991)
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/tcp/resource.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index ce60ae2e07..ce9d1fae12 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -323,7 +323,11 @@ class ReplicationStreamer(object): # We need to tell the presence handler that the connection has been # lost so that it can handle any ongoing syncs on that connection. - self.presence_handler.update_external_syncs_clear(connection.conn_id) + run_as_background_process( + "update_external_syncs_clear", + self.presence_handler.update_external_syncs_clear, + connection.conn_id, + ) def _batch_updates(updates): |