summary refs log tree commit diff
path: root/synapse/api/errors.py
diff options
context:
space:
mode:
authorSean Quah <seanq@matrix.org>2023-03-31 10:17:16 +0100
committerSean Quah <seanq@matrix.org>2023-03-31 10:17:16 +0100
commitbf81ee42178b45076422dff0976ba2105c12958c (patch)
tree18e7efae29394c3cdc0a3f88b645ac07f88c117f /synapse/api/errors.py
parentMerge remote-tracking branch 'origin/develop' into matrix-org-hotfixes (diff)
parentSet thread_id column to non-null for event_push_{actions,actions_staging,summ... (diff)
downloadsynapse-bf81ee42178b45076422dff0976ba2105c12958c.tar.xz
Merge remote-tracking branch 'origin/develop' into matrix-org-hotfixes
Diffstat (limited to 'synapse/api/errors.py')
-rw-r--r--synapse/api/errors.py17
1 files changed, 13 insertions, 4 deletions
diff --git a/synapse/api/errors.py b/synapse/api/errors.py

index 8c6822f3c6..f2d6f9ab2d 100644 --- a/synapse/api/errors.py +++ b/synapse/api/errors.py
@@ -27,7 +27,7 @@ from synapse.util import json_decoder if typing.TYPE_CHECKING: from synapse.config.homeserver import HomeServerConfig - from synapse.types import JsonDict + from synapse.types import JsonDict, StrCollection logger = logging.getLogger(__name__) @@ -682,18 +682,27 @@ class FederationPullAttemptBackoffError(RuntimeError): Attributes: event_id: The event_id which we are refusing to pull message: A custom error message that gives more context + retry_after_ms: The remaining backoff interval, in milliseconds """ - def __init__(self, event_ids: List[str], message: Optional[str]): - self.event_ids = event_ids + def __init__( + self, event_ids: "StrCollection", message: Optional[str], retry_after_ms: int + ): + event_ids = list(event_ids) if message: error_message = message else: - error_message = f"Not attempting to pull event_ids={self.event_ids} because we already tried to pull them recently (backing off)." + error_message = ( + f"Not attempting to pull event_ids={event_ids} because we already " + "tried to pull them recently (backing off)." + ) super().__init__(error_message) + self.event_ids = event_ids + self.retry_after_ms = retry_after_ms + class HttpResponseException(CodeMessageException): """