Skip to content

Commit

Permalink
chore(lint): fix rubocop offenses
Browse files Browse the repository at this point in the history
  • Loading branch information
marcosgz committed Feb 11, 2025
1 parent e3d64c0 commit 3b4a8fa
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion lib/lepus/consumer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -104,7 +104,7 @@ def process_delivery(delivery_info, metadata, payload)
nest_middleware(middleware, next_middleware)
end
.call(message)
rescue Exception => ex
rescue Exception => ex # rubocop:disable Lint/RescueException
# @TODO: add error handling
logger.error(ex)

Expand Down
4 changes: 2 additions & 2 deletions lib/lepus/processes/consumer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -104,9 +104,9 @@ def setup_consumer!
end
main_queue.subscribe_with(consumer_wrapper)
end
rescue Bunny::TCPConnectionFailed, Bunny::PossibleAuthenticationFailureError => e
rescue Bunny::TCPConnectionFailed, Bunny::PossibleAuthenticationFailureError
raise Lepus::ShutdownError
rescue Lepus::InvalidConsumerConfigError => e
rescue Lepus::InvalidConsumerConfigError
raise Lepus::ShutdownError
end
end
Expand Down
2 changes: 1 addition & 1 deletion lib/lepus/supervisor.rb
Original file line number Diff line number Diff line change
Expand Up @@ -177,7 +177,7 @@ def reap_and_replace_terminated_forks

def reap_terminated_forks
loop do
pid, status = ::Process.waitpid2(-1, ::Process::WNOHANG)
pid, _ = ::Process.waitpid2(-1, ::Process::WNOHANG)
break unless pid

# if (terminated_fork = forks.delete(pid)) && (!status.exited? || status.exitstatus > 0)
Expand Down

0 comments on commit 3b4a8fa

Please sign in to comment.