use std::time::Duration;
use anyhow::Result;
use super::RuntimeThreadManager;
use super::types::TurnRecord;
impl RuntimeThreadManager {
pub async fn wait_turn_terminal(&self, turn_id: &str, timeout: Duration) -> Result<TurnRecord> {
zagens_runtime_orchestrator::runtime_threads::turn_wait::wait_turn_terminal(
&self.store,
turn_id,
timeout,
)
.await
}
pub fn assistant_text_for_turn(&self, turn: &TurnRecord) -> Result<String> {
zagens_runtime_orchestrator::runtime_threads::turn_wait::assistant_text_for_turn(
&self.store,
turn,
)
}
}