Revert "Don't send catchup transactions for matrix hq"
This reverts commitsanoa/log_117725575b5cb43
,f271b32bea
,ffe17e47ce
parent
b18d18d03b
commit
b4bdab8e52
|
@ -287,13 +287,6 @@ class PerDestinationQueue:
|
||||||
len(pending_pdus),
|
len(pending_pdus),
|
||||||
)
|
)
|
||||||
|
|
||||||
# Filter out HQ traffic for now
|
|
||||||
pending_pdus = [
|
|
||||||
pdu
|
|
||||||
for pdu in pending_pdus
|
|
||||||
if pdu.room_id != "!OGEhHVWSdvArJzumhm:matrix.org"
|
|
||||||
]
|
|
||||||
|
|
||||||
await self._transaction_manager.send_new_transaction(
|
await self._transaction_manager.send_new_transaction(
|
||||||
self._destination, pending_pdus, pending_edus
|
self._destination, pending_pdus, pending_edus
|
||||||
)
|
)
|
||||||
|
|
|
@ -411,7 +411,6 @@ class TransactionWorkerStore(CacheInvalidationWorkerStore):
|
||||||
JOIN events USING (stream_ordering)
|
JOIN events USING (stream_ordering)
|
||||||
WHERE destination = ?
|
WHERE destination = ?
|
||||||
AND stream_ordering > ?
|
AND stream_ordering > ?
|
||||||
AND destination_rooms.room_id != '!OGEhHVWSdvArJzumhm:matrix.org'
|
|
||||||
ORDER BY stream_ordering
|
ORDER BY stream_ordering
|
||||||
LIMIT 50
|
LIMIT 50
|
||||||
"""
|
"""
|
||||||
|
|
Loading…
Reference in New Issue