diff options
| author | hera <matrix@template.upcloud.com> | 2017-10-12 10:50:44 +0000 |
|---|---|---|
| committer | hera <matrix@template.upcloud.com> | 2017-10-12 10:50:44 +0000 |
| commit | 8287457da5dd9b97c608d7279ac509303e07798e (patch) | |
| tree | 453c42e3559db376ca21bca6608cb1cfbe6b97c0 | |
| parent | Disable auth on room_members for now (diff) | |
| download | synapse-8287457da5dd9b97c608d7279ac509303e07798e.tar.xz | |
log when we get an exception handling replication updates
| -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 3ea3ca5a6f..6c1beca4e3 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -160,7 +160,11 @@ class ReplicationStreamer(object): "Getting stream: %s: %s -> %s", stream.NAME, stream.last_token, stream.upto_token ) - updates, current_token = yield stream.get_updates() + try: + updates, current_token = yield stream.get_updates() + except: + logger.info("Failed to handle stream %s", stream.NAME) + raise logger.debug( "Sending %d updates to %d connections", |