diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2021-03-29 11:43:20 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-03-29 11:43:20 -0400 |
| commit | da75d2ea1f2784791399dbeba16be401e2bb37d2 (patch) | |
| tree | 1ccbaf8cec32418a1cdbaae8b9197f6dc2c0bea1 /synapse/app/generic_worker.py | |
| parent | Update the OIDC sample config (#9695) (diff) | |
| download | synapse-da75d2ea1f2784791399dbeba16be401e2bb37d2.tar.xz | |
Add type hints for the federation sender. (#9681)
Includes an abstract base class which both the FederationSender and the FederationRemoteSendQueue must implement.
Diffstat (limited to 'synapse/app/generic_worker.py')
| -rw-r--r-- | synapse/app/generic_worker.py | 7 |
1 files changed, 0 insertions, 7 deletions
diff --git a/synapse/app/generic_worker.py b/synapse/app/generic_worker.py index 6139881dbb..3df2aa5c2b 100644 --- a/synapse/app/generic_worker.py +++ b/synapse/app/generic_worker.py @@ -787,13 +787,6 @@ class FederationSenderHandler: self._fed_position_linearizer = Linearizer(name="_fed_position_linearizer") - def on_start(self): - # There may be some events that are persisted but haven't been sent, - # so send them now. - self.federation_sender.notify_new_events( - self.store.get_room_max_stream_ordering() - ) - def wake_destination(self, server: str): self.federation_sender.wake_destination(server) |