diff --git a/synapse/handlers/worker_lock.py b/synapse/handlers/worker_lock.py index d743413e86..c87d02519b 100644 --- a/synapse/handlers/worker_lock.py +++ b/synapse/handlers/worker_lock.py @@ -247,6 +247,8 @@ class WaitingLock: timeout=self._get_next_retry_interval(), reactor=self.reactor, ) + # Let's reset retry interval since we got notified, we + # should only increase it if we hit the previous one self._retry_interval = 0.1 except Exception: pass