pub async fn current_run_id_for_thread( os: &Arc<AgentOs>, agent_id: &str, thread_id: &str, read_store: &dyn ThreadReader, ) -> Result<Option<String>, ApiError>