@@ -0,0 +394,4 @@
+                    resource_uri,
+                )
+                stored += 1
+            except Exception as exc:

@@ -0,0 +462,4 @@
+        """
+        if self._vector_backend is None:
+            return 0
+        placeholder_embedding = [float(len(content))]

@@ -0,0 +6,4 @@
+
+1. **Development placeholders** while physical store integrations are
+   built.
+2. **Test doubles** for indexer and pipeline tests without external

@@ -423,1 +425,4 @@
 
+    # ACMS UKO Indexer — real-time index synchronization (#578)
+    analyzer_registry = providers.Singleton(AnalyzerRegistry)
+    uko_indexer = providers.Singleton(

@@ -0,0 +327,4 @@
+            # new location are still tracked for this resource.
+            dest_path: str | None = None
+            if isinstance(event, FileMovedEvent):
+                dest_path = str(Path(str(event.dest_path)).resolve())

@@ -0,0 +444,4 @@
+            self._resource_subjects.pop(resource_id, None)
+            self._indexed_resources.pop(resource_id, None)
+            self._resource_analyzer.pop(resource_id, None)
+            self._resource_locks.pop(resource_id, None)

@@ -0,0 +41,4 @@
+    """Fire *on_indexed* lifecycle hook, guarding against failures."""
+    try:
+        hook.on_indexed(result)
+    except Exception:

@@ -0,0 +224,4 @@
+
+        # Re-open in text mode for proper UTF-8 decoding (the raw fd
+        # was opened non-blocking only for the fstat check).
+        os.close(fd)

@@ -86,3 +83,1 @@
-        if not value:
-            raise ValueError("predicate must not be empty.")
-        return value
+    @model_validator(mode="after")

@@ -0,0 +74,4 @@
+        if not self.doc_id:
+            raise ValueError("doc_id must be a non-empty string")
+        if not (0.0 <= self.score <= 1.0):
+            raise ValueError(f"score must be between 0.0 and 1.0, got {self.score}")

@@ -0,0 +305,4 @@
+        """Total number of stored embeddings (test helper)."""
+        return len(self._embeddings)
+
+

@@ -0,0 +331,4 @@
+                self._watched_paths.pop(src_path, None)
+                self._watched_paths[dest_path] = (resource_id, project)
+
+            existing = self._pending_timers.pop(src_path, None)

@@ -0,0 +366,4 @@
+        dest_path: str | None = None,
+    ) -> None:
+        """Fire the change callback and/or EventBus event after debounce."""
+        with self._lock:

@@ -0,0 +228,4 @@
+        # 2. Read resource content (I/O — outside global lock)
+        try:
+            content = self._content_reader.read_content(resource)
+        except (OSError, ValueError) as exc:

@@ -0,0 +405,4 @@
+        # leave the resource permanently stuck (P1 #4).
+        errors: list[str] = []
+        for subj in tracked_subjects:
+            try:

@@ -0,0 +151,4 @@
+        # URI-identified resource with a literal label), store the
+        # literal as a separate ``rdfs:label`` triple so no data is
+        # silently discarded.
+        if t.object_uri and t.object_value:

@@ -0,0 +46,4 @@
+    char_count: int = 0
+
+    def __post_init__(self) -> None:
+        if not self.project:

@@ -0,0 +259,4 @@
+            observer = self._observer
+            self._observer = None
+            self._dir_watches.clear()
+            self._running = False

@@ -0,0 +340,4 @@
+                args=(src_path, resource_id, project, change_type, dest_path),
+            )
+            timer.daemon = True
+            self._pending_timers[src_path] = timer

@@ -0,0 +145,4 @@
+        with self._lock:
+            lock = self._resource_locks.get(resource_id)
+            if lock is None:
+                lock = threading.Lock()

@@ -0,0 +222,4 @@
+                resource_id=resource.resource_id,
+                analyzer_domain="none",
+            )
+            fire_on_indexed(self._lifecycle_hook, result)

@@ -0,0 +241,4 @@
+        # 3. Produce UKO triples (CPU — outside global lock)
+        resource_uri = f"uko://resource/{resource.resource_id}"
+        try:
+            triples = analyzer.analyze(content, resource_uri)

@@ -0,0 +127,4 @@
+        if not obj:
+            continue
+        try:
+            graph_backend.add_triple(

@@ -0,0 +67,4 @@
+        description="Whether this triple reflects the latest state.",
+    )
+
+    model_config = ConfigDict(frozen=True)