Improve conditions

* Change of order * Use `conf.for_every_workers?` instead of `conf.target_worker_ids.empty?`. Signed-off-by: abetomo <[email protected]>
fluent · Mar 10, 2023 · a1b9913 · a1b9913
1 parent d691d6f
commit a1b9913
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/base.rb b/lib/fluent/plugin/base.rb
@@ -55,7 +55,7 @@ def fluentd_worker_id
       def configure(conf)
         raise ArgumentError, "BUG: type of conf must be Fluent::Config::Element, but #{conf.class} is passed." unless conf.is_a?(Fluent::Config::Element)
 
-        if (Fluent::Engine.supervisor_mode && !conf.target_worker_ids.empty?) || conf.for_this_worker?
+        if conf.for_this_worker? || (Fluent::Engine.supervisor_mode && !conf.for_every_workers?)
           system_config_override(workers: conf.target_worker_ids.size)
         end