Fix AS retries

This commit is contained in:
Erik Johnston 2016-06-07 09:34:50 +01:00
parent b0932b34cb
commit 310197bab5
2 changed files with 5 additions and 5 deletions

View file

@ -320,10 +320,10 @@ class ApplicationServiceTransactionStore(SQLBaseStore):
event_ids = json.loads(entry["event_ids"])
events = yield self.get_events(event_ids)
event_map = yield self.get_events(event_ids)
defer.returnValue(AppServiceTransaction(
service=service, id=entry["txn_id"], events=events
service=service, id=entry["txn_id"], events=event_map.values()
))
def _get_oldest_unsent_txn(self, txn, service):