lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.3 vs lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.4

@@ -236,9 +236,10 @@
       msgs << @dump_proc.call(header) << BODY_DELIMITER
       msgs << @dump_proc.call(record) << BODY_DELIMITER
     end
     if @pipeline
       msgs << "\"pipeline\" : \"" << @pipeline << "\"" << BODY_DELIMITER
+    end
   end
 
   def update_body(record, op)
     update = remove_keys(record)
     body = {"doc".freeze => update}