lib/backburner/worker.rb in backburner-allq-1.0.32 vs lib/backburner/worker.rb in backburner-allq-1.0.33
- old
+ new
@@ -44,10 +44,9 @@
pri: pri,
delay: delay,
ttr: ttr
}
opts.merge!(send_data)
-
response = connection.put(tube_name, serialized_data, opts)
end
return nil unless Backburner::Hooks.invoke_hook_events(job_class, :after_enqueue, *args)
ensure
connection.close if connection