diff options
| -rw-r--r-- | synapse/appservice/scheduler.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/synapse/appservice/scheduler.py b/synapse/appservice/scheduler.py index f130d4367d..d46d2fead2 100644 --- a/synapse/appservice/scheduler.py +++ b/synapse/appservice/scheduler.py @@ -113,20 +113,20 @@ class _ServiceQueuer(object): if service.id in self.requests_in_flight: return - with Measure(self.clock, "_ServiceQueuer._send_request"): - self.requests_in_flight.add(service.id) - try: - while True: - events = self.queued_events.pop(service.id, []) - if not events: - return + self.requests_in_flight.add(service.id) + try: + while True: + events = self.queued_events.pop(service.id, []) + if not events: + return + with Measure(self.clock, "_ServiceQueuer._send_request"): try: yield self.txn_ctrl.send(service, events) except: logger.exception("AS request failed") - finally: - self.requests_in_flight.discard(service.id) + finally: + self.requests_in_flight.discard(service.id) class _TransactionController(object): |