lib/rocket_job/sliced/writer/input.rb in rocketjob-4.1.0 vs lib/rocket_job/sliced/writer/input.rb in rocketjob-4.1.1

@@ -12,9 +12,11 @@
         #     Block to call on the first line only, instead of storing in the slice.
         #     Useful for extracting the header row
         #     Default: nil
         def self.collect(input, **args, &block)
           writer = new(input, **args)
+          # Create indexes before uploading
+          input.create_indexes if input.respond_to?(:create_indexes)
           block.call(writer)
           writer.record_count
         rescue Exception => exc
           # Drop input collection when upload fails
           input.drop