pub async fn query_agent_with_events( args: &QueryAgentArgs, ) -> Result<Receiver<AppEvent>, QueryAgentError>