1 files changed, 6 insertions, 6 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py
index 1c466cbded..963d938edd 100644
--- a/synapse/federation/transaction_queue.py
+++ b/synapse/federation/transaction_queue.py
@@ -233,16 +233,10 @@ class TransactionQueue(object):
consumeErrors=True
))
- events_processed_counter.inc_by(len(events))
-
yield self.store.update_federation_out_pos(
"events", next_token
)
- synapse.metrics.event_processing_positions.set(
- next_token, "federation_sender",
- )
-
if events:
now = self.clock.time_msec()
ts = yield self.store.get_received_ts(events[-1].event_id)
@@ -254,6 +248,12 @@ class TransactionQueue(object):
ts, "federation_sender",
)
+ events_processed_counter.inc_by(len(events))
+
+ synapse.metrics.event_processing_positions.set(
+ next_token, "federation_sender",
+ )
+
finally:
self._is_processing = False
|