fix: ignore runtime catalog mutations in supervisor watch

Author: myobie

src/run.rs

@@ -831,14 +831,9 @@ fn gate_codex_launches<'a, V, F>(
     let mut workspaces = Vec::new();
     let mut gated_agents = Vec::new();
     for launch in &plan.launch {
-        let Some(agent) = launch
-            .tasks
-            .iter()
-            .find(|target| {
-                target.name == "agent"
-                    && crate::hooks::command_invokes_codex(&target.command)
-            })
-        else {
+        let Some(agent) = launch.tasks.iter().find(|target| {
+            target.name == "agent" && crate::hooks::command_invokes_codex(&target.command)
+        }) else {
             continue;
         };
         let spec_dir = launch.spec.path.parent().unwrap_or_else(|| Path::new("."));
@@ -1118,7 +1113,7 @@ fn up_loop_until(
     mut on_report: impl FnMut(&UpReport),
 ) -> anyhow::Result<()> {
     let (tx, rx) = channel::<()>();
-    let _watcher = crate::watch::watch_recursive_mutations(root, tx);
+    let _watcher = crate::watch::watch_catalog_declarations(root, tx);
     let mut cap = FlappingCap::default();
     // Carries per-id liveness across passes so a transient `pty list` flicker under load isn't
     // destructively GC'd (R21c). Fresh throwaway in `up_once` — a single pass has no flicker to absorb.
@@ -1907,5 +1902,4 @@ mod tests {
         assert!(!h.is_empty());
         assert!(!h.contains('.'), "short name only, got {h}");
     }
-
 }

src/watch.rs

@@ -25,6 +25,42 @@ pub(crate) fn watch_recursive_mutations(
     Some(watcher)
 }
 
+/// Watch only declaration inputs for the supervisor. Runtime state (PTY registry, bus, logs,
+/// locks, inboxes, and generated materializations) must never wake reconciliation.
+pub(crate) fn watch_catalog_declarations(
+    root: &Path,
+    tx: Sender<()>,
+) -> Option<notify::RecommendedWatcher> {
+    let root = root.to_path_buf();
+    let callback_root = root.clone();
+    let mut watcher = notify::recommended_watcher(move |result: notify::Result<Event>| {
+        if result.is_ok_and(|event| {
+            is_mutation(&event)
+                && event
+                    .paths
+                    .iter()
+                    .any(|path| is_declaration_path(&callback_root, path))
+        }) {
+            let _ = tx.send(());
+        }
+    })
+    .ok()?;
+    watcher.watch(&root, RecursiveMode::Recursive).ok()?;
+    Some(watcher)
+}
+
+fn is_declaration_path(root: &Path, path: &Path) -> bool {
+    let rel = path.strip_prefix(root).unwrap_or(path);
+    let mut components = rel.components();
+    if matches!(
+        components.next().and_then(|c| c.as_os_str().to_str()),
+        Some("_templates")
+    ) {
+        return true;
+    }
+    path.file_name().and_then(|n| n.to_str()) == Some("agent.kdl")
+}
+
 fn is_mutation(event: &Event) -> bool {
     matches!(
         event.kind,
@@ -60,6 +96,31 @@ mod tests {
         }
     }
 
+    #[test]
+    fn declaration_filter_ignores_runtime_state() {
+        let root = Path::new("/catalog");
+        assert!(is_declaration_path(
+            root,
+            Path::new("/catalog/team/agent.kdl")
+        ));
+        assert!(is_declaration_path(
+            root,
+            Path::new("/catalog/_templates/base.kdl")
+        ));
+        assert!(!is_declaration_path(
+            root,
+            Path::new("/catalog/pty/session.json")
+        ));
+        assert!(!is_declaration_path(
+            root,
+            Path::new("/catalog/bus/inbox/msg")
+        ));
+        assert!(!is_declaration_path(
+            root,
+            Path::new("/catalog/team/rendered.kdl")
+        ));
+    }
+
     #[cfg(target_os = "linux")]
     #[test]
     fn linux_reads_are_silent_but_real_mutations_wake() {