lib/rocket_job/sliced/input.rb in rocketjob-5.3.3 vs lib/rocket_job/sliced/input.rb in rocketjob-5.4.0.beta1
- old
+ new
@@ -3,11 +3,11 @@
class Input < Slices
def upload(on_first: nil, &block)
# Create indexes before uploading
create_indexes
Writer::Input.collect(self, on_first: on_first, &block)
- rescue StandardError => e
+ rescue Exception => e
drop
raise(e)
end
def upload_mongo_query(criteria, *column_names, &block)
@@ -71,11 +71,11 @@
create!(records: [[start_id, end_id]])
start_id += slice_size
count += 1
end
count
- rescue StandardError => e
+ rescue Exception => e
drop
raise(e)
end
def upload_integer_range_in_reverse_order(start_id, last_id)
@@ -89,10 +89,10 @@
create!(records: [[first_id, end_id]])
end_id -= slice_size
count += 1
end
count
- rescue StandardError => e
+ rescue Exception => e
drop
raise(e)
end
# Iterate over each failed record, if any