lib/deimos/kafka_topic_info.rb in deimos-ruby-1.6.4 vs lib/deimos/kafka_topic_info.rb in deimos-ruby-1.7.0.pre.beta1
- old
+ new
@@ -12,10 +12,10 @@
# @return [Boolean]
def lock(topic, lock_id)
# Try to create it - it's fine if it already exists
begin
self.create(topic: topic)
- rescue ActiveRecord::RecordNotUnique # rubocop:disable Lint/SuppressedException
+ rescue ActiveRecord::RecordNotUnique
# continue on
end
# Lock the record
qtopic = self.connection.quote(topic)