diff options
| author | hera <matrix@template.upcloud.com> | 2017-10-12 10:50:44 +0000 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2017-10-12 11:51:24 +0100 |
| commit | f807f7f80442aec48a5e1f6b6b6f1a88e707b1e2 (patch) | |
| tree | 9757e71e617355e52f2c312753945ab913fa7db8 /synapse/replication | |
| parent | Merge pull request #2531 from matrix-org/dbkr/spamcheck_error_messages (diff) | |
| download | synapse-f807f7f80442aec48a5e1f6b6b6f1a88e707b1e2.tar.xz | |
log when we get an exception handling replication updates
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 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", |