equal
deleted
inserted
replaced
122 # reindex entities by generating rql queries which set all indexable |
122 # reindex entities by generating rql queries which set all indexable |
123 # attribute to their current value |
123 # attribute to their current value |
124 source = repo.system_source |
124 source = repo.system_source |
125 for eschema in etypes: |
125 for eschema in etypes: |
126 etype_class = cnx.vreg['etypes'].etype_class(str(eschema)) |
126 etype_class = cnx.vreg['etypes'].etype_class(str(eschema)) |
127 for fti_rql in etype_class.cw_fti_index_rql_queries(cnx): |
127 for rset in etype_class.cw_fti_index_rql_limit(cnx): |
128 rset = cnx.execute(fti_rql) |
|
129 source.fti_index_entities(cnx, rset.entities()) |
128 source.fti_index_entities(cnx, rset.entities()) |
130 # clear entity cache to avoid high memory consumption on big tables |
129 # clear entity cache to avoid high memory consumption on big tables |
131 cnx.drop_entity_cache() |
130 cnx.drop_entity_cache() |
132 if withpb: |
131 if withpb: |
133 pb.update() |
132 pb.update() |