Skip to content

Commit 2591d15

Browse files
authored
Merge pull request #300 from Shopify/cbruckmayer/fix-rescue
Fix rescue
2 parents d23f35d + 5cc9f0c commit 2591d15

3 files changed

Lines changed: 5 additions & 4 deletions

File tree

ruby/lib/ci/queue.rb

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,8 @@ module Queue
2121

2222
attr_accessor :shuffler, :requeueable
2323

24+
Error = Class.new(StandardError)
25+
2426
module Warnings
2527
RESERVED_LOST_TEST = :RESERVED_LOST_TEST
2628
end

ruby/lib/ci/queue/redis.rb

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,8 @@
1414
module CI
1515
module Queue
1616
module Redis
17-
Error = Class.new(StandardError)
18-
LostMaster = Class.new(Error)
19-
ReservationError = Class.new(Error)
17+
LostMaster = Class.new(CI::Queue::Error)
18+
ReservationError = Class.new(CI::Queue::Error)
2019

2120
class << self
2221

ruby/lib/minitest/queue.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ def run_from_queue(reporter, *)
266266
reopen_previous_step
267267
puts red("The heartbeat process died. This worker is exiting early.")
268268
exit!(41)
269-
rescue CI::Queue::Redis::Error
269+
rescue CI::Queue::Error
270270
reopen_previous_step
271271
puts red("#{error.class}: #{error.message}")
272272
error.backtrace.each do |frame|

0 commit comments

Comments
 (0)