diff options
| author | Erik Johnston <erik@matrix.org> | 2015-02-18 11:17:26 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2015-02-18 11:17:26 +0000 |
| commit | b17bd31da0574cf335f90763dee2708af40ac87f (patch) | |
| tree | 69e818e8428632e6610b042daa9e7749577e0de8 /synapse/util/retryutils.py | |
| parent | Don't convert DNSLookupError to a 4xx SynapseError (diff) | |
| download | synapse-b17bd31da0574cf335f90763dee2708af40ac87f.tar.xz | |
Temporarily add a run_on_reactor() call
Diffstat (limited to 'synapse/util/retryutils.py')
| -rw-r--r-- | synapse/util/retryutils.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/synapse/util/retryutils.py b/synapse/util/retryutils.py index ac30545079..ee1194f1de 100644 --- a/synapse/util/retryutils.py +++ b/synapse/util/retryutils.py @@ -17,6 +17,8 @@ from twisted.internet import defer from synapse.api.errors import CodeMessageException +from synapse.util.async import run_on_reactor + import logging @@ -52,6 +54,7 @@ def get_retry_limiter(destination, clock, store, **kwargs): # We aren't ready to retry that destination. raise """ + yield run_on_reactor() retry_last_ts, retry_interval = (0, 0) retry_timings = yield store.get_destination_retry_timings( |