lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.7 vs lib/fluent/plugin/out_elasticsearch.rb in fluent-plugin-es-mohit-1.9.8

@@ -235,10 +235,10 @@
       header[INDEX_OP] = meta
       msgs << @dump_proc.call(header) << BODY_DELIMITER
       msgs << @dump_proc.call(record) << BODY_DELIMITER
     end
     if @pipeline
-      msgs << "{\"pipeline\": \"" << @pipeline << "\"}" << BODY_DELIMITER
+      msgs << "{\"pipeline\":{\"pipeline\": \"" << @pipeline << "\"}}" << BODY_DELIMITER
     end
   end
 
   def update_body(record, op)
     update = remove_keys(record)