diff options
| author | Andrew Morgan <andrew@amorgan.xyz> | 2020-02-13 11:29:37 +0000 |
|---|---|---|
| committer | Andrew Morgan <andrew@amorgan.xyz> | 2020-02-13 11:30:15 +0000 |
| commit | 28eba8747eb0a5f88f7bb96b93ef43c12d53b9de (patch) | |
| tree | ab19276f5d3334627f606019d165807396b107d1 /synapse/federation | |
| parent | Dinsic Blacking with black==18.6b2 (diff) | |
| parent | Run Black. (#5482) (diff) | |
| download | synapse-28eba8747eb0a5f88f7bb96b93ef43c12d53b9de.tar.xz | |
Run Black. (#5482)
Diffstat (limited to 'synapse/federation')
| -rw-r--r-- | synapse/federation/sender/__init__.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/federation/sender/__init__.py b/synapse/federation/sender/__init__.py index 45eea4870e..356e887bde 100644 --- a/synapse/federation/sender/__init__.py +++ b/synapse/federation/sender/__init__.py @@ -45,7 +45,7 @@ sent_pdus_destination_dist_count = Counter( sent_pdus_destination_dist_total = Counter( "synapse_federation_client_sent_pdu_destinations:total", - "" "Total number of PDUs queued for sending across all destinations", + "Total number of PDUs queued for sending across all destinations", ) @@ -109,7 +109,9 @@ class FederationSender(object): # awaiting a call to flush_read_receipts_for_room. The presence of an entry # here for a given room means that we are rate-limiting RR flushes to that room, # and that there is a pending call to _flush_rrs_for_room in the system. - self._queues_awaiting_rr_flush_by_room = {} # type: dict[str, set[PerDestinationQueue]] + self._queues_awaiting_rr_flush_by_room = ( + {} + ) # type: dict[str, set[PerDestinationQueue]] self._rr_txn_interval_per_room_ms = ( 1000.0 / hs.get_config().federation_rr_transactions_per_room_per_second |