Skip to content
This repository was archived by the owner on Apr 26, 2024. It is now read-only.

Wait for streams to catch up when processing HTTP replication. #14820

Merged
merged 10 commits into from
Jan 18, 2023
Prev Previous commit
Next Next commit
Make ClassVar
  • Loading branch information
erikjohnston committed Jan 18, 2023
commit 01ae502c0c8dfa5b758f2ba023ef1a2b55d50645
4 changes: 2 additions & 2 deletions synapse/replication/http/_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
import re
import urllib.parse
from inspect import signature
from typing import TYPE_CHECKING, Any, Awaitable, Callable, Dict, List, Tuple
from typing import TYPE_CHECKING, Any, Awaitable, Callable, ClassVar, Dict, List, Tuple

from prometheus_client import Counter, Gauge

Expand Down Expand Up @@ -111,7 +111,7 @@ class ReplicationEndpoint(metaclass=abc.ABCMeta):
RETRY_ON_CONNECT_ERROR = True
RETRY_ON_CONNECT_ERROR_ATTEMPTS = 5 # =63s (2^6-1)

WAIT_FOR_STREAMS = True
WAIT_FOR_STREAMS: ClassVar[bool] = True

def __init__(self, hs: "HomeServer"):
if self.CACHE:
Expand Down