This commit is contained in:
Josh Hawkins 2024-10-10 14:14:50 -05:00
parent d6d1108620
commit a68f1593fb
2 changed files with 4 additions and 5 deletions

View File

@ -153,14 +153,12 @@ class Dispatcher:
def handle_update_embeddings_reindex_progress(): def handle_update_embeddings_reindex_progress():
self.embeddings_reindex = payload self.embeddings_reindex = payload
logger.info(self.embeddings_reindex)
self.publish( self.publish(
"embeddings_reindex_progress", "embeddings_reindex_progress",
json.dumps(payload), json.dumps(payload),
) )
def handle_embeddings_reindex_progress(): def handle_embeddings_reindex_progress():
logger.info(self.embeddings_reindex)
self.publish( self.publish(
"embeddings_reindex_progress", "embeddings_reindex_progress",
json.dumps(self.embeddings_reindex.copy()), json.dumps(self.embeddings_reindex.copy()),

View File

@ -218,8 +218,8 @@ class Embeddings:
totals["processed_objects"] += 1 totals["processed_objects"] += 1
# report progress every 10 events so we don't spam the logs or websocket # report progress every 10 events so we don't spam the logs
if (processed_events % 10) == 0: if (totals["processed_objects"] % 10) == 0:
progress = (processed_events / total_events) * 100 progress = (processed_events / total_events) * 100
logger.debug( logger.debug(
"Processed %d/%d events (%.2f%% complete) | Thumbnails: %d, Descriptions: %d", "Processed %d/%d events (%.2f%% complete) | Thumbnails: %d, Descriptions: %d",
@ -229,7 +229,8 @@ class Embeddings:
totals["thumbnails"], totals["thumbnails"],
totals["descriptions"], totals["descriptions"],
) )
self.requestor.send_data(UPDATE_EMBEDDINGS_REINDEX_PROGRESS, totals)
self.requestor.send_data(UPDATE_EMBEDDINGS_REINDEX_PROGRESS, totals)
# Move to the next page # Move to the next page
current_page += 1 current_page += 1