diff options
author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2018-04-27 11:47:21 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-04-27 11:47:21 +0100 |
commit | 53494c34df323db5e5319f5594d64ff1d9c2bb33 (patch) | |
tree | f229d34ab66d4bb9275db27fd7ab92a8cc71a22b /synapse/storage | |
parent | Merge tag 'v0.28.0' (diff) | |
parent | Add missing consumeErrors (diff) | |
download | synapse-53494c34df323db5e5319f5594d64ff1d9c2bb33.tar.xz |
Merge pull request #3139 from matrix-org/rav/consume_errors
Add missing consumeErrors to improve exception handling
Diffstat (limited to 'synapse/storage')
-rw-r--r-- | synapse/storage/stream.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py index 2956c3b3e0..3b8b539993 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py @@ -202,7 +202,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): room_id, from_key, to_key, limit, order=order, ) for room_id in rm_ids - ])) + ], consumeErrors=True)) results.update(dict(zip(rm_ids, res))) defer.returnValue(results) |