Skip to content

Commit 3951035

Browse files
authored
in_obsolete_plugins: support multi worker (#11)
If confiured using multi worker, `in_obsolete_plugins` causes following config error. ### config ``` <system> workers 2 </system> <source> @type obsolete_plugins </source> ``` ### error ``` 2025-08-27 17:12:31 +0900 [error]: config error file="/home/watson/prj/sandbox/fluentd/fluent.conf" error_class=Fluent::ConfigError error="Plugin 'obsolete_plugins' does not support multi workers configuration (Fluent::Plugin::ObsoletePluginsInput)" ``` This PR will solve above config error.
1 parent 70ebf06 commit 3951035

File tree

3 files changed

+22
-0
lines changed

3 files changed

+22
-0
lines changed

lib/fluent/plugin/in_obsolete_plugins.rb

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,10 @@ class ObsoletePluginsInput < Fluent::Plugin::Input
1515
desc "Raise error if obsolete plugins are detected"
1616
config_param :raise_error, :bool, default: false
1717

18+
def multi_workers_ready?
19+
true
20+
end
21+
1822
def configure(conf)
1923
super
2024

test/plugin/test_filter_obsolete_plugins.rb

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,15 @@ class ObsoletePluginsFilterTest < Test::Unit::TestCase
1414
Timecop.return
1515
end
1616

17+
test "multi worker" do
18+
config = %[
19+
obsolete_plugins_yml #{fixture_path("obsolete-plugins.yml")}
20+
]
21+
22+
d = create_driver(config)
23+
assert_true d.instance.multi_workers_ready?
24+
end
25+
1726
sub_test_case "obsolete_plugins_yml" do
1827
CONFIG_YAML = %[
1928
obsolete_plugins_yml #{fixture_path("obsolete-plugins.yml")}

test/plugin/test_in_obsolete_plugins.rb

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,15 @@ class ObsoletePluginsInputTest < Test::Unit::TestCase
1515
Timecop.return
1616
end
1717

18+
test "multi worker" do
19+
config = %[
20+
obsolete_plugins_yml #{fixture_path("obsolete-plugins.yml")}
21+
]
22+
23+
d = create_driver(config)
24+
assert_true d.instance.multi_workers_ready?
25+
end
26+
1827
sub_test_case "plugins_json" do
1928
CONFIG_JSON = %[
2029
plugins_json #{fixture_path("plugins.json")}

0 commit comments

Comments
 (0)