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