diff options
author | Sean Quah <8349537+squahtx@users.noreply.github.com> | 2021-12-14 17:35:28 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-12-14 17:35:28 +0000 |
commit | 0147b3de20f313975226a9a3f319c77b90aa2793 (patch) | |
tree | 7dfe4b6dd7832999241defb5cbf06894f9f1342d /synapse/federation | |
parent | Add missing type hints to `synapse.appservice` (#11360) (diff) | |
download | synapse-0147b3de20f313975226a9a3f319c77b90aa2793.tar.xz |
Add missing type hints to `synapse.logging.context` (#11556)
Diffstat (limited to 'synapse/federation')
-rw-r--r-- | synapse/federation/federation_server.py | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/synapse/federation/federation_server.py b/synapse/federation/federation_server.py index 8e37e76206..cf067b56c6 100644 --- a/synapse/federation/federation_server.py +++ b/synapse/federation/federation_server.py @@ -30,7 +30,6 @@ from typing import ( from prometheus_client import Counter, Gauge, Histogram -from twisted.internet import defer from twisted.internet.abstract import isIPAddress from twisted.python import failure @@ -67,7 +66,7 @@ from synapse.replication.http.federation import ( from synapse.storage.databases.main.lock import Lock from synapse.types import JsonDict, get_domain_from_id from synapse.util import glob_to_regex, json_decoder, unwrapFirstError -from synapse.util.async_helpers import Linearizer, concurrently_execute +from synapse.util.async_helpers import Linearizer, concurrently_execute, gather_results from synapse.util.caches.response_cache import ResponseCache from synapse.util.stringutils import parse_server_name @@ -360,13 +359,13 @@ class FederationServer(FederationBase): # want to block things like to device messages from reaching clients # behind the potentially expensive handling of PDUs. pdu_results, _ = await make_deferred_yieldable( - defer.gatherResults( - [ + gather_results( + ( run_in_background( self._handle_pdus_in_txn, origin, transaction, request_time ), run_in_background(self._handle_edus_in_txn, origin, transaction), - ], + ), consumeErrors=True, ).addErrback(unwrapFirstError) ) |