lib/fluent/plugin/out_rename_key.rb in fluent-plugin-rename-key-0.4.0 vs lib/fluent/plugin/out_rename_key.rb in fluent-plugin-rename-key-0.4.1

@@ -26,9 +26,13 @@
     raise Fluent::ConfigError, 'No rename nor replace rules are given' if @rename_rules.empty? && @replace_rules.empty?
 
     @remove_tag_prefix = /^#{Regexp.escape @remove_tag_prefix}\.?/ if @remove_tag_prefix
   end
 
+  def multi_workers_ready?
+    true
+  end
+
   def process tag, es
     es.each do |time, record|
       new_tag = @remove_tag_prefix ? tag.sub(@remove_tag_prefix, '') : tag
       new_tag = "#{new_tag}.#{@append_tag}".sub(/^\./, '')
       new_record = rename_key record