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