Skip to content
Snippets Groups Projects
Commit b9158ac2 authored by Erik Johnston's avatar Erik Johnston
Browse files

Remove get_destination_retry_timings cache

Currently we rely on the master to invalidate this cache promptly.
However, after having moved most federation endpoints off of master this
no longer happens, causing outbound fedeariont to get blackholed.

Fixes #3798
parent 05b9937c
No related branches found
No related tags found
Loading
......@@ -156,7 +156,6 @@ class TransactionStore(SQLBaseStore):
"""
pass
@cached(max_entries=10000)
def get_destination_retry_timings(self, destination):
"""Gets the current retry timings (if any) for a given destination.
......@@ -212,10 +211,6 @@ class TransactionStore(SQLBaseStore):
retry_last_ts, retry_interval):
self.database_engine.lock_table(txn, "destinations")
self._invalidate_cache_and_stream(
txn, self.get_destination_retry_timings, (destination,)
)
# We need to be careful here as the data may have changed from under us
# due to a worker setting the timings.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment