fix queues value

[nisyuu]

Fixes #153.

The undefined method to_sym is occurred when queues have array in a sidekiq.yml. If queues have queue name and weighting, config[:queues] also get queue name and weighting. I think that config[:queues] have only queue name. Therefore , I tried to get only the queue name if config[:queues] have weighting besides queue name.

[javinto]

I tried your fix. Starting Sidekiq now works as expected, but exiting Sidekiq leads to the following exception

/Users/me/.rvm/gems/ruby-3.1.2@project/gems/sidekiq-7.0.3/lib/sidekiq/fetch.rb:31:in initialize': undefined method queues' for Sidekiq:Module (NoMethodError)

  raise ArgumentError, "missing queue list" unless cap.queues
                                                      ^^^^^^^
from /Users/me/.rvm/gems/ruby-3.1.2@project/bundler/gems/sidekiq-limit_fetch-97084a6352bd/lib/sidekiq/limit_fetch.rb:56:in `new'
from /Users/me/.rvm/gems/ruby-3.1.2@projectbundler/gems/sidekiq-limit_fetch-97084a6352bd/lib/sidekiq/limit_fetch.rb:56:in `bulk_requeue'

[nisyuu]

Thank you for your comment.
I pushed new commit. Can you check the behavior?

[javinto]

Hi, I tried again but weirdly enough I get the original exception back: undefined method `to_sym' for ["active_storage_analysis", 4]:Array queue.process_limit = @process_limits[queue_name.to_s] || @process_limits[queue_name.to_sym] ^^^^^^^ Did you mean? to_s to_set ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/limit_fetch/queues.rb:139:in `apply_process_limit_to_queue' ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/limit_fetch/queues.rb:133:in `block in apply_process_limit_to_queues' ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/limit_fetch/queues.rb:132:in `each' ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/limit_fetch/queues.rb:132:in `apply_process_limit_to_queues' ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/limit_fetch/queues.rb:34:in `start' ***@***.***/bundler/gems/sidekiq-limit_fetch-9ba331acab4c/lib/sidekiq/extensions/manager.rb:17:in `start' ***@***.***/gems/sidekiq-7.0.3/lib/sidekiq/launcher.rb:42:in `each' As you can see I use Sidekiq 7.0.3. And used this in my gemfile for your Fork: gem "sidekiq-limit_fetch", git: "https://github.com/uichi/sidekiq-limit_fetch.git"

…

Op 18 jan. 2023, om 17:54 heeft uichi ***@***.***> het volgende geschreven: Thank you for your comment. I pushed new commit. Can you check the behavior? — Reply to this email directly, view it on GitHub <#155 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AACY2N2S25JHDRJ7OUOOMXLWTAN6HANCNFSM6AAAAAAT5XUJUM>. You are receiving this because you commented.

[nisyuu]

Thank you.
Did you use sidekiq-v7-fix-queues-value branch of my Fork ? I tried fixed sidekiq-limit_fetch on my development environment and no problems occurred.

[javinto]

Yes, that was it! Thanks! I forgot to mention the branch. It starts and stops without exceptions now.

…

Op 19 jan. 2023, om 12:18 heeft uichi ***@***.***> het volgende geschreven: Thank you. Did you use sidekiq-v7-fix-queues-value branch of my Fork ? I tried fixed sidekiq-limit_fetch on my development environment and no problems occurred. — Reply to this email directly, view it on GitHub <#155 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/AACY2N7CS4M7NJX6TCAAHD3WTEPHBANCNFSM6AAAAAAT5XUJUM>. You are receiving this because you commented.

[deanpcmad]

Thanks!