From a25d329f64f11d5f18a0f728b25b2aba846b481f Mon Sep 17 00:00:00 2001 From: Jake Landis Date: Tue, 18 Jul 2017 14:52:51 -0500 Subject: [PATCH] Test Failure Fix: Retry pipeline metrics Fixes #7724 Fixes #7728 --- logstash-core/spec/logstash/pipeline_spec.rb | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/logstash-core/spec/logstash/pipeline_spec.rb b/logstash-core/spec/logstash/pipeline_spec.rb index 6d62fba7be7..1a235f791c0 100644 --- a/logstash-core/spec/logstash/pipeline_spec.rb +++ b/logstash-core/spec/logstash/pipeline_spec.rb @@ -5,6 +5,7 @@ require_relative "../support/mocks_classes" require_relative "../support/helpers" require_relative "../logstash/pipeline_reporter_spec" # for DummyOutput class +require "stud/try" class DummyInput < LogStash::Inputs::Base config_name "dummyinput" @@ -799,10 +800,12 @@ class TestPipeline < LogStash::Pipeline sleep(0.1) until subject.ready? # make sure we have received all the generated events - wait(3).for do - # give us a bit of time to flush the events - dummyoutput.events.size >= number_of_events - end.to be_truthy + Stud.try(10.times, [StandardError, RSpec::Expectations::ExpectationNotMetError]) do + wait(3).for do + # give us a bit of time to flush the events + dummyoutput.events.size >= number_of_events + end.to be_truthy + end end after :each do