equal
deleted
inserted
replaced
129 pb.update() |
129 pb.update() |
130 # reindex entities by generating rql queries which set all indexable |
130 # reindex entities by generating rql queries which set all indexable |
131 # attribute to their current value |
131 # attribute to their current value |
132 source = repo.system_source |
132 source = repo.system_source |
133 for eschema in etypes: |
133 for eschema in etypes: |
134 for entity in session.execute('Any X WHERE X is %s' % eschema).entities(): |
134 rset = session.execute('Any X WHERE X is %s' % eschema) |
135 source.fti_index_entity(session, entity) |
135 source.fti_index_entities(session, rset.entities()) |
136 if withpb: |
136 if withpb: |
137 pb.update() |
137 pb.update() |
138 |
138 |
139 |
139 |
140 def check_schema(schema, session, eids, fix=1): |
140 def check_schema(schema, session, eids, fix=1): |