[API] Refactors logging in wipe cluster

Author: picandocodigo

api-spec-testing/logging.rb

@@ -0,0 +1,28 @@
+# Licensed to Elasticsearch B.V. under one or more contributor
+# license agreements. See the NOTICE file distributed with
+# this work for additional information regarding copyright
+# ownership. Elasticsearch B.V. licenses this file to you under
+# the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+
+require 'logger'
+
+module Elasticsearch
+  module RestAPIYAMLTests
+    module Logging
+      def logger
+        @logger ||= Logger.new($stdout)
+      end
+    end
+  end
+end

api-spec-testing/wipe_cluster.rb

@@ -15,6 +15,9 @@
 # specific language governing permissions and limitations
 # under the License.
 
+require_relative 'logging'
+include Elasticsearch::RestAPIYAMLTests::Logging
+
 module Elasticsearch
   module RestAPIYAMLTests
     module WipeCluster
@@ -81,7 +84,7 @@ def wait_for_pending_tasks(client)
             results.each do |task|
               next if task.empty?
 
-              LOGGER.debug "Pending task: #{task}"
+              logger.debug "Pending task: #{task}"
               count += 1 if task.include?(filter)
             end
             break unless count.positive? && Time.now.to_i < (time + 30)
@@ -97,7 +100,7 @@ def wait_for_cluster_tasks(client)
             results['tasks'].each do |task|
               next if task.empty?
 
-              LOGGER.debug "Pending cluster task: #{task}"
+              logger.debug "Pending cluster task: #{task}"
               count += 1
             end
             break unless count.positive? && Time.now.to_i < (time + 30)
@@ -286,7 +289,7 @@ def clear_datastreams(client)
           begin
             client.xpack.indices.delete_data_stream(name: '*', expand_wildcards: 'all')
           rescue StandardError => e
-            LOGGER.error "Caught exception attempting to delete data streams: #{e}"
+            logger.error "Caught exception attempting to delete data streams: #{e}"
             client.xpack.indices.delete_data_stream(name: '*')
           end
         end

elasticsearch-xpack/spec/xpack/rest_api_yaml_spec.rb

@@ -69,7 +69,7 @@
 
             after(:all) do
               test_file.teardown
-              Elasticsearch::RestAPIYAMLTests::TestFile.wipe_cluster(ADMIN_CLIENT)
+              Elasticsearch::RestAPIYAMLTests::WipeCluster.run(ADMIN_CLIENT)
             end
 
             test.task_groups.each do |task_group|