pub async fn execute_jq<E: CommandExecutor>( executor: &E, request: Request, jq: String, agent_arguments: Option<&AgentArguments>, ) -> Result<E::Stream<Value>, E::Error>