Actually use async method

1 files changed, 1 insertions, 3 deletions

diff --git a/synapse/storage/_base.py b/synapse/storage/_base.py

index f6c1ec424a..0ba12d48a5 100644
--- a/synapse/storage/_base.py
+++ b/synapse/storage/_base.py
@@ -873,9 +873,7 @@ class SQLBaseStore(object):
         N = 50  # Only fetch 100 events at a time.
 
         ds = [
-            self.runInteraction(
-                desc,
-                self._fetch_events_txn,
+            self._fetch_events(
                 event_ids[i*N:(i+1)*N],
                 check_redacted=check_redacted,
                 get_prev_content=get_prev_content,