Skip to content

Commit abe335a

Browse files
authored
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 <[email protected]>
1 parent b9fc438 commit abe335a

File tree

1 file changed

+12
-7
lines changed

1 file changed

+12
-7
lines changed

test/plugin/test_out_exec_filter.rb

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -500,10 +500,18 @@ def create_driver(conf)
500500
d = create_driver(conf)
501501
time = event_time('2011-01-02 13:14:15')
502502

503-
d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: true, shutdown: false){ d.feed(time, {"k1" => 0}) }
504-
d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 1}) }
505-
d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 2}) }
506-
d.run(default_tag: 'test', expect_emits: 1, timeout: 10, start: false, shutdown: false){ d.feed(time, {"k1" => 3}) }
503+
d.run(default_tag: 'test', expect_emits: 4) do
504+
d.feed(time, {"k1" => 0})
505+
d.flush
506+
sleep 0.5
507+
d.feed(time, {"k1" => 1})
508+
d.flush
509+
sleep 0.5
510+
d.feed(time, {"k1" => 2})
511+
d.flush
512+
sleep 0.5
513+
d.feed(time, {"k1" => 3})
514+
end
507515

508516
assert_equal "2011-01-02 13:14:15\ttest\t0\n", d.formatted[0]
509517
assert_equal "2011-01-02 13:14:15\ttest\t1\n", d.formatted[1]
@@ -524,9 +532,6 @@ def create_driver(conf)
524532
assert_equal pid_list[1], events[1][2]['child_pid']
525533
assert_equal pid_list[0], events[2][2]['child_pid']
526534
assert_equal pid_list[1], events[3][2]['child_pid']
527-
528-
ensure
529-
d.run(start: false, shutdown: true)
530535
end
531536

532537
# child process exits per 3 lines

0 commit comments

Comments
 (0)