Temporarily add a run_on_reactor() call

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(