swarm repositories / source
aboutsummaryrefslogtreecommitdiff
path: root/crates/phone-opus/src/mcp/host/runtime.rs
diff options
context:
space:
mode:
authormain <main@swarm.moe>2026-03-23 19:16:10 -0400
committermain <main@swarm.moe>2026-03-23 19:16:10 -0400
commit00949559a8a4757e1198e1ea582ebfcf7268fec4 (patch)
tree7bb8821c1d597eb386998a6f0b4cba1b9e24de41 /crates/phone-opus/src/mcp/host/runtime.rs
parentdd2b64ed08b8ac55d6aaeb54d635b33b51eea790 (diff)
downloadphone_opus-00949559a8a4757e1198e1ea582ebfcf7268fec4.zip
Add blocking wait for background consult jobs
Diffstat (limited to 'crates/phone-opus/src/mcp/host/runtime.rs')
-rw-r--r--crates/phone-opus/src/mcp/host/runtime.rs11
1 files changed, 10 insertions, 1 deletions
diff --git a/crates/phone-opus/src/mcp/host/runtime.rs b/crates/phone-opus/src/mcp/host/runtime.rs
index 688ffd6..df54844 100644
--- a/crates/phone-opus/src/mcp/host/runtime.rs
+++ b/crates/phone-opus/src/mcp/host/runtime.rs
@@ -25,7 +25,9 @@ use crate::mcp::protocol::{
FORCE_ROLLOUT_ENV, HOST_STATE_ENV, HostRequestId, HostStateSeed, PROTOCOL_VERSION, SERVER_NAME,
WORKER_CRASH_ONCE_ENV, WorkerOperation, WorkerSpawnConfig,
};
-use crate::mcp::service::{consult_job_tool_output, consult_jobs_tool_output};
+use crate::mcp::service::{
+ consult_job_tool_output, consult_jobs_tool_output, consult_wait_tool_output,
+};
use crate::mcp::telemetry::ServerTelemetry;
pub(crate) fn run_host() -> Result<(), Box<dyn std::error::Error>> {
@@ -371,6 +373,13 @@ impl HostRuntime {
FaultStage::Host,
&operation,
),
+ "consult_wait" => tool_success(
+ consult_wait_tool_output(arguments, generation, FaultStage::Host, &operation)?,
+ presentation,
+ generation,
+ FaultStage::Host,
+ &operation,
+ ),
"consult_jobs" => tool_success(
consult_jobs_tool_output(arguments, generation, FaultStage::Host, &operation)?,
presentation,