summary refs log tree commit diff
path: root/synapse/replication/tcp/resource.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-02-26 15:33:26 +0000
committerGitHub <noreply@github.com>2020-02-26 15:33:26 +0000
commit1f773eec912e4908ab60f7823f5c0a024261af4d (patch)
tree3b75bb043a46554b1296003cd9974a0b35ce6a8c /synapse/replication/tcp/resource.py
parentUpdated warning for incorrect database collation/ctype (#6985) (diff)
downloadsynapse-1f773eec912e4908ab60f7823f5c0a024261af4d.tar.xz
Port PresenceHandler to async/await (#6991)
Diffstat (limited to 'synapse/replication/tcp/resource.py')
-rw-r--r--synapse/replication/tcp/resource.py6
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):