From b17bd31da0574cf335f90763dee2708af40ac87f Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Wed, 18 Feb 2015 11:17:26 +0000 Subject: [PATCH] Temporarily add a run_on_reactor() call --- synapse/util/retryutils.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/synapse/util/retryutils.py b/synapse/util/retryutils.py index ac3054507..ee1194f1d 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(