build: Migrate to Obelisk 0.40.0

Author: tomasol

DESIGN.md

@@ -93,8 +93,8 @@ agent loop, each turn:
   respId = responseSubmit(joinSet)                     // child id created here
   reqId  = requestSubmit(raceSet, respId, prefix_hash) // params expose respId + key
   raceSet.submitDelay(idle)                            // persistent sleep
-  winner = raceSet.joinNext()                          // request stub OR idle
-  delta  = obelisk.getResult(reqId)                    // -> delta JSON
+  delta  = raceSet.joinNext()                          // request value, or null for idle delay
+  assert(raceSet.lastId == reqId)                      // confirms the request stub won
   session.send(delta); reply = session.recv()
   responseStub(respId, { ok: replyJson })              // self-fulfil the reply
   // loop with the new committed history

deployment.toml

@@ -148,7 +148,7 @@ params = [
 ]
 return_type = "result<string, string>"
 location = "workflow/agent-loop.js"
-content_digest = "sha256:1582fe14211a65f2a728c210426d306ad3bea6ec8339d947ed045108998bdb11"
+content_digest = "sha256:fa2e7164dde2c0db619f0eb1360d1218e71759b81c09ba12140a2e54ccdb32a6"
 
 # --- Chat-completions webhook -------------------------------------------------
 

dev-deps.txt

@@ -1,2 +1,2 @@
-obelisk 0.39.5
+obelisk 0.40.0
 node.js v22.23.1

flake.lock

@@ -5,3 +5,11 @@ api.listening_addr = "127.0.0.1:5105"       # gRPC/REST API; matches OBELISK_API
 webui.listening_addr = "127.0.0.1:8180"     # Web UI
 external.listening_addr = "127.0.0.1:9190"  # external HTTP server; serves POST /v1/chat/completions
 database.sqlite.directory = "${DATA_DIR}/obelisk-sqlite-agent-backed-llm-server"
+
+allow_exec_activities = [
+  "sha256:52394d8c340e8ae59527ccc7bd425f46a35f928a28caf919e0c74ac1774c7aae", # claude.start (agent-backed-llm:agent/claude.start)
+  "sha256:52394d8c340e8ae59527ccc7bd425f46a35f928a28caf919e0c74ac1774c7aae", # codex.start (agent-backed-llm:agent/codex.start)
+  "sha256:536a62d943260b22abcd501467cc819534b18a9cc930e238f0103afdc3e5bac4", # session.send (agent-backed-llm:agent/session.send)
+  "sha256:b1a0cb695e54841f4c3cbe1c2ed28f944c0321a0ee9bf6e552a8360fa74fba86", # session.recv (agent-backed-llm:agent/session.recv)
+  "sha256:29350a3896ee19e9cf005669bfd2e60d6483f7178d33142a2689c8d5480dc2d6", # session.cleanup (agent-backed-llm:agent/session.cleanup)
+]

server.toml

@@ -70,22 +70,21 @@ export default function agentLoopCancellable(socketPath, systemPrompt, maxTurns)
 //   { respSet, respId, delta } | null (idle timeout).
 function awaitTurn(committed, turn) {
     const respSet = obelisk.createJoinSet({ name: `response-${turn}` });
-    const respId = responseSubmit(respSet);
+    const respId = responseSubmit(respSet); // Webhook will receive the answer here
 
     const raceSet = obelisk.createJoinSet({ name: `request-${turn}` });
     const reqId = requestSubmit(raceSet, respId, committed);
-    raceSet.submitDelay(IDLE_TIMEOUT);
+    const delayId = raceSet.submitDelay(IDLE_TIMEOUT);
 
     try {
-        const winner = raceSet.joinNext();
-        if (winner.type === "delay") {
-            // Idle: no request arrived in time. Drop the unanswered response stub.
+        const delta = raceSet.joinNext();
+        if (raceSet.lastId == delayId) {
+            // Drop the unanswered response stub.
             responseStub(respId, { err: "session idle timeout" });
             respSet.close();
             return null;
         }
-        const delta = obelisk.getResult(reqId);   // ok = the delta JSON string
-        if (typeof delta !== "string") throw `turn.request returned an unexpected value: ${JSON.stringify(delta)}`;
+        // stub activity turn_request won, meaning webhook received a request for this workflow
         return { respSet, respId, delta };
     } finally {
         // Cancel the losing idle delay once the request stub has completed.