--- a/server/checkintegrity.py	Mon Jan 24 19:09:42 2011 +0100
+++ b/server/checkintegrity.py	Tue Feb 01 11:52:10 2011 +0100
@@ -129,8 +129,8 @@
     # attribute to their current value
     source = repo.system_source
     for eschema in etypes:
-        for entity in session.execute('Any X WHERE X is %s' % eschema).entities():
-            source.fti_index_entity(session, entity)
+        rset = session.execute('Any X WHERE X is %s' % eschema)
+        source.fti_index_entities(session, rset.entities())
         if withpb:
             pb.update()