pub async fn execute_transform<E: CommandExecutor>( executor: &E, request: Request, transform: Transform, agent_arguments: Option<&AgentArguments>, ) -> Result<Pin<Box<dyn Stream<Item = Result<Value, E::Error>> + Send>>, E::Error>