diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-07-23 16:47:36 -0400 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-07-23 16:47:36 -0400 |
| commit | fefe9943ef008b00bc85f80a486323279e63d117 (patch) | |
| tree | 20f36b6567bf8f265100053c2b8c3b37e4e07b39 /synapse/federation/sender/__init__.py | |
| parent | Update the auth providers to be async. (#7935) (diff) | |
| download | synapse-fefe9943ef008b00bc85f80a486323279e63d117.tar.xz | |
Convert presence handler helpers to async/await. (#7939)
Diffstat (limited to 'synapse/federation/sender/__init__.py')
| -rw-r--r-- | synapse/federation/sender/__init__.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/federation/sender/__init__.py b/synapse/federation/sender/__init__.py index b328a4df09..99ce73e081 100644 --- a/synapse/federation/sender/__init__.py +++ b/synapse/federation/sender/__init__.py @@ -453,7 +453,9 @@ class FederationSender(object): """Given a list of states populate self.pending_presence_by_dest and poke to send a new transaction to each destination """ - hosts_and_states = yield get_interested_remotes(self.store, states, self.state) + hosts_and_states = yield defer.ensureDeferred( + get_interested_remotes(self.store, states, self.state) + ) for destinations, states in hosts_and_states: for destination in destinations: |