feat: run agents through Fabric's fabric-agent-ctl

.github/workflows/images.yml

@@ -55,7 +55,7 @@ jobs:
         if: needs.plan.outputs.images == 'true'
         run: |
           cargo images build --platform "$AGENT_PLATFORM" dummy
-          cargo images qualify nc-fabric:dummy --lifecycle dummy --require-ready
+          cargo images qualify nc-fabric:dummy --lifecycle dummy
       - name: Check packaging and generic Fabric lifecycle
         if: needs.plan.outputs.images == 'true'
         run: docker buildx bake check

crates/fabric-provider/src/agent.rs

@@ -11,7 +11,7 @@ use nemoclaw_fabric::agent::{
 use openshell_provider::OpenShell;
 use std::borrow::Cow;
 
-/// Reconciles agents through the Fabric bridge of their sandbox.
+/// Starts and stops agents through Fabric's `fabric-agent-ctl` in their sandbox.
 #[derive(Clone)]
 pub struct AgentBackend(pub OpenShell);
 
@@ -29,7 +29,7 @@ fn configuration_row(row: &Row) -> Result<Row, ObservationError> {
 /// observed document differs from the one they compose.
 fn agent_row(agent: &Row, configured: &Row, observed: &Row) -> Row {
     let mut row = agent.clone();
-    for field in ["id", "running"] {
+    for field in ["id", "runtime_id"] {
         if let Some(value) = observed.get(field) {
             row.insert(field.into(), value.clone());
         }
@@ -116,15 +116,15 @@ fn sandbox_kept(
 
 /// The Fabric agent resource and its planning rules.
 pub fn definitions() -> [nemoclaw_tofu::Definition; 1] {
-    use nemoclaw_tofu::{Definition, rerun_when_stopped};
+    use nemoclaw_tofu::{Definition, carry_prior};
     let references = agent::references();
     let inputs = agent::structured_inputs();
     let carried: Vec<&'static str> = references
         .iter()
         .flat_map(|reference| reference.fields.iter().map(|(_, field)| *field))
         .collect();
     let sections: Vec<&'static str> = inputs.iter().map(|input| input.field).collect();
-    let fields: Vec<&'static str> = [NAME, DESCRIPTION, "running"]
+    let fields: Vec<&'static str> = [NAME, DESCRIPTION, "runtime_id"]
         .into_iter()
         .chain(carried.iter().copied())
         .chain(sections.iter().copied())
@@ -133,7 +133,7 @@ pub fn definitions() -> [nemoclaw_tofu::Definition; 1] {
     // A changed agent is a new agent in a new sandbox. Another endpoint is
     // another gateway; credentials rotate in place. A newer image catalog for
     // the same harness changes no agent.
-    let mutable: Vec<&'static str> = [HARNESS_CATALOG, "running"]
+    let mutable: Vec<&'static str> = [HARNESS_CATALOG, "runtime_id"]
         .into_iter()
         .chain(gateway[1..].iter().copied())
         .collect();
@@ -144,7 +144,8 @@ pub fn definitions() -> [nemoclaw_tofu::Definition; 1] {
         .collect();
     let mut definition = Definition::new("agent", &fields, &mutable)
         .optional(&optional)
-        .computed("running", rerun_when_stopped)
+        // The ID Fabric gives the sandbox's one runtime, for invocations.
+        .computed("runtime_id", carry_prior)
         .validate_inputs(validate)
         .refuse_replacement_when(sandbox_kept)
         // Readiness compares the applied document with this digest.