async fn run_loop( mstore: Arc<Store>, agents: Arc<Mutex<HashSet<String>>>, ctrl_rx: UnboundedReceiver<CtrlMsg>, )