Skip to content

Commit 5bb275b

Browse files
committed
Use transaction
1 parent f1943f5 commit 5bb275b

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed

import.rb

Lines changed: 12 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -9,15 +9,17 @@
99

1010
list = params[:list]
1111

12-
(params[:from]..params[:to]).each do |seq|
13-
begin
14-
message = Message.from_s3(list, seq)
15-
message.save
16-
rescue ActiveRecord::RecordNotUnique
17-
STDERR.puts("#{list}:#{seq} already exists in Postgres")
18-
rescue Aws::S3::Errors::NoSuchKey
19-
STDERR.puts("#{list}:#{seq} doesn't exist in S3")
20-
rescue StandardError => e
21-
STDERR.puts("failed to import #{list}:#{seq}: #{e}")
12+
Message.transaction do
13+
(params[:from]..params[:to]).each do |seq|
14+
begin
15+
message = Message.from_s3(list, seq)
16+
message.save!
17+
rescue ActiveRecord::RecordNotUnique
18+
STDERR.puts("#{list}:#{seq} already exists in Postgres")
19+
rescue Aws::S3::Errors::NoSuchKey
20+
STDERR.puts("#{list}:#{seq} doesn't exist in S3")
21+
rescue StandardError => e
22+
STDERR.puts("failed to import #{list}:#{seq}: #{e}")
23+
end
2224
end
2325
end

0 commit comments

Comments
 (0)