diff options
| author | David Baker <dave@matrix.org> | 2017-10-10 11:20:17 +0100 |
|---|---|---|
| committer | David Baker <dave@matrix.org> | 2017-10-10 11:20:17 +0100 |
| commit | 89fa00ddff2abe08c402267353d700cfc8aa0769 (patch) | |
| tree | 01e2b818689718d028812931d7de1544cf96ac3f /synapse/util/async.py | |
| parent | Make be faster (diff) | |
| parent | Merge pull request #2520 from matrix-org/rav/process_incoming_rooms_in_parallel (diff) | |
| download | synapse-89fa00ddff2abe08c402267353d700cfc8aa0769.tar.xz | |
Merge branch 'develop' into dbkr/channel_notifications
Diffstat (limited to 'synapse/util/async.py')
| -rw-r--r-- | synapse/util/async.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/util/async.py b/synapse/util/async.py index 1453faf0ef..bb252f75d7 100644 --- a/synapse/util/async.py +++ b/synapse/util/async.py @@ -19,7 +19,7 @@ from twisted.internet import defer, reactor from .logcontext import ( PreserveLoggingContext, preserve_fn, preserve_context_over_deferred, ) -from synapse.util import unwrapFirstError +from synapse.util import logcontext, unwrapFirstError from contextlib import contextmanager @@ -155,7 +155,7 @@ def concurrently_execute(func, args, limit): except StopIteration: pass - return preserve_context_over_deferred(defer.gatherResults([ + return logcontext.make_deferred_yieldable(defer.gatherResults([ preserve_fn(_concurrently_execute_inner)() for _ in xrange(limit) ], consumeErrors=True)).addErrback(unwrapFirstError) |