lib/rocket_job/batch/io.rb in rocketjob-6.1.0 vs lib/rocket_job/batch/io.rb in rocketjob-6.1.1

- old
+ new

@@ -464,9 +464,11 @@ stream.writer(**args) do |io| # TODO: Binary formats should return the record count, instead of the slice count. output_collection.download(header_line: binary_header_line) { |record| io.write(record) } end else + # TODO: Add category to named tags to aid problem determination + # And RJ Download metric with duration IOStreams.new(stream || category.file_name).writer(:line, **args) do |io| output_collection.download(header_line: header_line) { |record| io << record } end end end