LOG.warning("Starting indexing boundaries using %s threads",
len(self.threads))
- for rank in range(max(minrank, 5), min(maxrank, 26)):
+ for rank in range(max(minrank, 4), min(maxrank, 26)):
self.index(BoundaryRunner(rank))
def index_by_rank(self, minrank, maxrank):
else:
self.index(RankRunner(maxrank))
+ def update_status_table(self):
+ """ Update the status in the status table to 'indexed'.
+ """
+ with self.conn.cursor() as cur:
+ cur.execute('UPDATE import_status SET indexed = true')
+ self.conn.commit()
+
def index(self, obj, batch=1):
""" Index a single rank or table. `obj` describes the SQL to use
for indexing. `batch` describes the number of objects that