lib/sneakers/worker.rb in sneakers-1.0.2 vs lib/sneakers/worker.rb in sneakers-1.0.3
- old
+ new
@@ -48,10 +48,10 @@
res = nil
error = nil
begin
metrics.increment("work.#{self.class.name}.started")
- Timeout.timeout(@timeout_after) do
+ Timeout.timeout(@timeout_after, Timeout::Error) do
metrics.timing("work.#{self.class.name}.time") do
if @call_with_params
res = work_with_params(msg, delivery_info, metadata)
else
res = work(msg)