|
@@ -387,6 +387,11 @@ class ClusterFeedbackService {
|
|
updatesForClusterSummary[clusterID] =
|
|
updatesForClusterSummary[clusterID] =
|
|
(avgEmbeedingBuffer, embedings.length);
|
|
(avgEmbeedingBuffer, embedings.length);
|
|
}
|
|
}
|
|
|
|
+ // store the intermediate updates
|
|
|
|
+ if (updatesForClusterSummary.length > 100) {
|
|
|
|
+ await faceMlDb.clusterSummaryUpdate(updatesForClusterSummary);
|
|
|
|
+ updatesForClusterSummary.clear();
|
|
|
|
+ }
|
|
clusterAvg[clusterID] = avg;
|
|
clusterAvg[clusterID] = avg;
|
|
}
|
|
}
|
|
if (updatesForClusterSummary.isNotEmpty) {
|
|
if (updatesForClusterSummary.isNotEmpty) {
|