diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2018-04-30 01:02:25 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-04-30 01:02:25 +0100 |
| commit | db75c86e8463b130d4dcd84e79c1ebee616f9689 (patch) | |
| tree | b7c0c3e9262f8ca27470a0151cb5109472da20fa /synapse/util/async.py | |
| parent | Move more xrange to six (diff) | |
| parent | Merge pull request #3085 from NotAFile/py3-config-text-mode (diff) | |
| download | synapse-db75c86e8463b130d4dcd84e79c1ebee616f9689.tar.xz | |
Merge branch 'develop' into py3-xrange-1
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 cb53c31123..9dd4e6b5bc 100644 --- a/synapse/util/async.py +++ b/synapse/util/async.py @@ -19,7 +19,7 @@ from twisted.internet.defer import CancelledError from twisted.python import failure from .logcontext import ( - PreserveLoggingContext, make_deferred_yieldable, preserve_fn + PreserveLoggingContext, make_deferred_yieldable, run_in_background ) from synapse.util import logcontext, unwrapFirstError @@ -165,7 +165,7 @@ def concurrently_execute(func, args, limit): pass return logcontext.make_deferred_yieldable(defer.gatherResults([ - preserve_fn(_concurrently_execute_inner)() + run_in_background(_concurrently_execute_inner) for _ in range(limit) ], consumeErrors=True)).addErrback(unwrapFirstError) |