|
|
@@ -3,12 +3,12 @@
|
|
|
(:require [clojure.string :as string]
|
|
|
[datascript.core :as d]
|
|
|
[frontend.common.thread-api :as thread-api]
|
|
|
+ [frontend.worker.db-sync :as db-sync]
|
|
|
[frontend.worker.pipeline :as worker-pipeline]
|
|
|
[frontend.worker.rtc.gen-client-op :as gen-client-op]
|
|
|
[frontend.worker.search :as search]
|
|
|
[frontend.worker.shared-service :as shared-service]
|
|
|
[frontend.worker.state :as worker-state]
|
|
|
- [frontend.worker.db-sync :as db-sync]
|
|
|
[logseq.common.util :as common-util]
|
|
|
[logseq.db :as ldb]
|
|
|
[logseq.outliner.batch-tx :as batch-tx]
|
|
|
@@ -62,8 +62,10 @@
|
|
|
(->> (d/datoms @conn :avet :logseq.property.embedding/hnsw-label-updated-at)
|
|
|
(map (fn [d]
|
|
|
[:db/retract (:e d) :logseq.property.embedding/hnsw-label-updated-at]))))
|
|
|
- ;; Mark vector embedding
|
|
|
- mark-embedding-tx-data (->> (keep (fn [datom] (when (and (= :block/title (:a datom)) (:added datom) (not (string/blank? (:v datom))))
|
|
|
+ ;; Mark vector embedding
|
|
|
+ mark-embedding-tx-data (->> (keep (fn [datom] (when (and (= :block/title (:a datom))
|
|
|
+ (:added datom)
|
|
|
+ (not (string/blank? (:block/title (d/entity @conn (:e datom))))))
|
|
|
(:e datom))) tx-data)
|
|
|
;; Mark block embedding to be computed
|
|
|
(map (fn [id] [:db/add id :logseq.property.embedding/hnsw-label-updated-at 0])))
|
Tienson Qin