diff --git a/frigate/comms/dispatcher.py b/frigate/comms/dispatcher.py index d407c8033..c1a9f7e86 100644 --- a/frigate/comms/dispatcher.py +++ b/frigate/comms/dispatcher.py @@ -153,14 +153,12 @@ class Dispatcher: def handle_update_embeddings_reindex_progress(): self.embeddings_reindex = payload - logger.info(self.embeddings_reindex) self.publish( "embeddings_reindex_progress", json.dumps(payload), ) def handle_embeddings_reindex_progress(): - logger.info(self.embeddings_reindex) self.publish( "embeddings_reindex_progress", json.dumps(self.embeddings_reindex.copy()), diff --git a/frigate/embeddings/embeddings.py b/frigate/embeddings/embeddings.py index 311068ae6..dda4d95fd 100644 --- a/frigate/embeddings/embeddings.py +++ b/frigate/embeddings/embeddings.py @@ -218,8 +218,8 @@ class Embeddings: totals["processed_objects"] += 1 - # report progress every 10 events so we don't spam the logs or websocket - if (processed_events % 10) == 0: + # report progress every 10 events so we don't spam the logs + if (totals["processed_objects"] % 10) == 0: progress = (processed_events / total_events) * 100 logger.debug( "Processed %d/%d events (%.2f%% complete) | Thumbnails: %d, Descriptions: %d", @@ -229,7 +229,8 @@ class Embeddings: totals["thumbnails"], 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 current_page += 1