diff options
| author | main <main@swarm.moe> | 2026-03-23 19:16:10 -0400 |
|---|---|---|
| committer | main <main@swarm.moe> | 2026-03-23 19:16:10 -0400 |
| commit | 00949559a8a4757e1198e1ea582ebfcf7268fec4 (patch) | |
| tree | 7bb8821c1d597eb386998a6f0b4cba1b9e24de41 /crates/phone-opus/src/mcp/host/runtime.rs | |
| parent | dd2b64ed08b8ac55d6aaeb54d635b33b51eea790 (diff) | |
| download | phone_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.rs | 11 |
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, |