Get an auth query one at a time

synapse/storage/event_federation.py

@@ -55,17 +55,16 @@ class EventFederationStore(SQLBaseStore):
         results = set()
 
         base_sql = (
-            "SELECT auth_id FROM event_auth WHERE %s"
+            "SELECT auth_id FROM event_auth WHERE event_id = ?"
         )
 
         front = set(event_ids)
         while front:
-            sql = base_sql % (
+            new_front = set()
-                " OR ".join(["event_id=?"] * len(front)),
+            for f in front:
-            )
+                txn.execute(base_sql, (f,))
-
+                new_front.update([r[0] for r in txn.fetchall()])
-            txn.execute(sql, list(front))
+            front = new_front
-            front = [r[0] for r in txn.fetchall()]
             results.update(front)
 
         return list(results)