fix race condition in agent spec

Fixes #4912
This commit is contained in:
Joao Duarte 2016-03-29 14:24:48 +01:00 committed by João Duarte
parent 5808782345
commit 002060cfdf

View file

@ -123,6 +123,7 @@ describe LogStash::Agent do
allow(subject).to receive(:clean_state?).and_return(false)
expect(subject).to receive(:reload_state!).at_least(3).times
t = Thread.new { subject.execute }
sleep 0.01 until subject.running_pipelines? && subject.pipelines.values.first.ready?
sleep 0.1
Stud.stop!(t)
t.join