From abe335a1031abd74b2d8fbc2460e080fbbb072f2 Mon Sep 17 00:00:00 2001 From: Shizuo Fujita Date: Mon, 6 Jan 2025 18:50:14 +0900 Subject: [PATCH] test_out_exec_filter: add a sleep to ensure the stream is emitted (#4755) **Which issue(s) this PR fixes**: Fixes #4754 **What this PR does / why we need it**: This PR will stable the tests. **Docs Changes**: **Release Note**: Signed-off-by: Shizuo Fujita --- test/plugin/test_out_exec_filter.rb | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/test/plugin/test_out_exec_filter.rb b/test/plugin/test_out_exec_filter.rb index 5a7dc71044..2a0276a9cd 100644 --- a/test/plugin/test_out_exec_filter.rb +++ b/test/plugin/test_out_exec_filter.rb @@ -500,10 +500,18 @@ def create_driver(conf) d = create_driver(conf) time = event_time('2011-01-02 13:14:15') - d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: true, shutdown: false){ d.feed(time, {"k1" => 0}) } - d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 1}) } - d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 2}) } - d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 3}) } + d.run(default_tag: 'test', expect_emits: 4) do + d.feed(time, {"k1" => 0}) + d.flush + sleep 0.5 + d.feed(time, {"k1" => 1}) + d.flush + sleep 0.5 + d.feed(time, {"k1" => 2}) + d.flush + sleep 0.5 + d.feed(time, {"k1" => 3}) + end assert_equal "2011-01-02 13:14:15\ttest\t0\n", d.formatted[0] assert_equal "2011-01-02 13:14:15\ttest\t1\n", d.formatted[1] @@ -524,9 +532,6 @@ def create_driver(conf) assert_equal pid_list[1], events[1][2]['child_pid'] assert_equal pid_list[0], events[2][2]['child_pid'] assert_equal pid_list[1], events[3][2]['child_pid'] - - ensure - d.run(start: false, shutdown: true) end # child process exits per 3 lines