mirror of
https://mau.dev/maunium/synapse.git
synced 2024-08-26 12:16:12 +00:00
Merge pull request #2975 from matrix-org/rav/measure_persist_events
Add Measure block for persist_events
This commit is contained in:
commit
299fd740c7
@ -283,10 +283,11 @@ class EventsStore(EventsWorkerStore):
|
|||||||
def _maybe_start_persisting(self, room_id):
|
def _maybe_start_persisting(self, room_id):
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def persisting_queue(item):
|
def persisting_queue(item):
|
||||||
yield self._persist_events(
|
with Measure(self._clock, "persist_events"):
|
||||||
item.events_and_contexts,
|
yield self._persist_events(
|
||||||
backfilled=item.backfilled,
|
item.events_and_contexts,
|
||||||
)
|
backfilled=item.backfilled,
|
||||||
|
)
|
||||||
|
|
||||||
self._event_persist_queue.handle_queue(room_id, persisting_queue)
|
self._event_persist_queue.handle_queue(room_id, persisting_queue)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user