diff --git a/synapse/federation/sender/per_destination_queue.py b/synapse/federation/sender/per_destination_queue.py index af85fe0a1ec1..68e47cdca22d 100644 --- a/synapse/federation/sender/per_destination_queue.py +++ b/synapse/federation/sender/per_destination_queue.py @@ -480,6 +480,8 @@ async def _catch_up_transmission_loop(self) -> None: # the other sending servers are up). if new_pdus: room_catchup_pdus = new_pdus + else: + room_catchup_pdus[pdu] logger.info( "Catching up rooms to %s: %r", self._destination, pdu.room_id