summary refs log tree commit diff
path: root/synapse/replication/tcp/resource.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-03-24 13:24:54 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-03-24 13:24:54 +0000
commitb2e71e372efe6b29679aa4be3f799d54bd82e953 (patch)
tree1caaea6f179d52f4e1d0f9855106fc4295ec8c40 /synapse/replication/tcp/resource.py
parentUpdated warning for incorrect database collation/ctype (#6985) (diff)
parentPort PresenceHandler to async/await (#6991) (diff)
downloadsynapse-b2e71e372efe6b29679aa4be3f799d54bd82e953.tar.xz
Port PresenceHandler to async/await (#6991)
* commit '1f773eec9':
  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):