summary refs log tree commit diff
path: root/synapse/util/retryutils.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2015-02-18 11:17:26 +0000
committerErik Johnston <erik@matrix.org>2015-02-18 11:17:26 +0000
commitb17bd31da0574cf335f90763dee2708af40ac87f (patch)
tree69e818e8428632e6610b042daa9e7749577e0de8 /synapse/util/retryutils.py
parentDon't convert DNSLookupError to a 4xx SynapseError (diff)
downloadsynapse-b17bd31da0574cf335f90763dee2708af40ac87f.tar.xz
Temporarily add a run_on_reactor() call
Diffstat (limited to '')
-rw-r--r--synapse/util/retryutils.py3
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(