diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2021-03-03 15:47:38 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-03-03 15:47:38 -0500 |
| commit | 33a02f0f52a5cd793c0d123463d8a7a1e3f4f198 (patch) | |
| tree | 0d53722ffb90376b2998bdf2f206e3b9d76da9d3 /synapse/replication/tcp/client.py | |
| parent | Set X-Forwarded-Proto header when frontend-proxy proxies a request (#9539) (diff) | |
| download | synapse-33a02f0f52a5cd793c0d123463d8a7a1e3f4f198.tar.xz | |
Fix additional type hints from Twisted upgrade. (#9518)
Diffstat (limited to 'synapse/replication/tcp/client.py')
| -rw-r--r-- | synapse/replication/tcp/client.py | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index 2618eb1e53..3455839d67 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -108,9 +108,7 @@ class ReplicationDataHandler: # Map from stream to list of deferreds waiting for the stream to # arrive at a particular position. The lists are sorted by stream position. - self._streams_to_waiters = ( - {} - ) # type: Dict[str, List[Tuple[int, Deferred[None]]]] + self._streams_to_waiters = {} # type: Dict[str, List[Tuple[int, Deferred]]] async def on_rdata( self, stream_name: str, instance_name: str, token: int, rows: list |