Publish model state and embeddings reindex in dispatcher onConnect

This commit is contained in:
Josh Hawkins 2024-10-13 18:47:15 -05:00
parent 833768172d
commit 2f0ef1dc69

View File

@ -179,6 +179,11 @@ class Dispatcher:
}
self.publish("camera_activity", json.dumps(camera_status))
self.publish("model_state", json.dumps(self.model_state.copy()))
self.publish(
"embeddings_reindex_progress",
json.dumps(self.embeddings_reindex.copy()),
)
# Dictionary mapping topic to handlers
topic_handlers = {