Class Worker has 79 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Worker
    include Resque::Helpers
    extend Resque::Helpers
    include Resque::Logging

File worker.rb has 633 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'time'
require 'set'
require 'redis/distributed'

module Resque

Class WebRunner has 32 methods (exceeds 20 allowed). Consider refactoring.

Open

  class WebRunner
    attr_reader :app, :app_name, :filesystem_friendly_app_name,
      :rack_handler, :port, :options, :args

    PORT       = 5678

File resque.rb has 321 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'mono_logger'
require 'redis/namespace'
require 'forwardable'

require 'resque/version'

File web_runner.rb has 301 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'open-uri'
require 'logger'
require 'optparse'
require 'fileutils'
require 'rack'

Class Job has 27 methods (exceeds 20 allowed). Consider refactoring.

Open

  class Job
    include Helpers
    extend Helpers
    def redis
      Resque.redis

Method work has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    def work(interval = 5.0, &block)
      interval = Float(interval)
      startup

      loop do

• Read up
  Read up

Method new_kill_child has a Cognitive Complexity of 22 (exceeds 5 allowed). Consider refactoring.

Open

    def new_kill_child
      if @child
        unless child_already_exited?
          if pre_shutdown_timeout && pre_shutdown_timeout > 0.0
            log_with_severity :debug, "Waiting #{pre_shutdown_timeout.to_f}s for child process to exit"

• Read up
  Read up

Method prune_dead_workers has a Cognitive Complexity of 19 (exceeds 5 allowed). Consider refactoring.

Open

    def prune_dead_workers
      return unless data_store.acquire_pruning_dead_worker_lock(self, Resque.heartbeat_interval)

      all_workers = Worker.all

• Read up
  Read up

Method setup_rack_handler has a Cognitive Complexity of 17 (exceeds 5 allowed). Consider refactoring.

Open

    def setup_rack_handler
      # First try to set Rack handler via a special hook we honor
      @rack_handler = if @app.respond_to?(:detect_rack_handler)
        @app.detect_rack_handler

• Read up
  Read up

Method page_entries_info has a Cognitive Complexity of 16 (exceeds 5 allowed). Consider refactoring.

Open

    def page_entries_info(start, stop, size, name = nil)
      if size == 0
        name ? "No #{name}s" : '<b>0</b>'
      elsif size == 1
        'Showing <b>1</b>' + (name ? " #{name}" : '')

• Read up
  Read up

File data_store.rb has 253 lines of code (exceeds 250 allowed). Consider refactoring.

Open

module Resque
  # An interface between Resque's persistence and the actual
  # implementation.
  class DataStore
    extend Forwardable

Method perform has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def perform
      job = payload_class
      job_args = args || []
      job_was_performed = false

Method unregister_worker has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def unregister_worker(exception = nil)
      # If we're still processing a job, make sure it gets logged as a
      # failure.
      if (hash = processing) && !hash.empty?
        job = Job.new(hash['queue'], hash['payload'])

• Read up
  Read up

Method initialize has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def initialize(*runtime_args)
      @options = runtime_args.last.is_a?(Hash) ? runtime_args.pop : {}

      self.class.logger.level = options[:debug] ? Logger::DEBUG : Logger::INFO

• Read up
  Read up

Method each has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def self.each(offset = 0, limit = self.count, queue = :failed, class_name = nil, order = 'desc')
        if class_name
          original_limit = limit
          limit = count
        end

• Read up
  Read up

Method each has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

      def self.each(offset = 0, limit = self.count, queue = :failed, class_name = nil, order = 'desc')
        items = all(offset, limit, queue)
        items = [items] unless items.is_a? Array
        reversed = false
        if order.eql? 'desc'

• Read up
  Read up

Method constantize has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

  def constantize(camel_cased_word)
    camel_cased_word = camel_cased_word.to_s

    if camel_cased_word.include?('-')
      camel_cased_word = classify(camel_cased_word)

• Read up
  Read up

Method working has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def self.working
      names = all
      return [] unless names.any?

      reportedly_working = {}

• Read up
  Read up

Method run_hook has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

    def run_hook(name, *args)
      hooks = Resque.send(name)
      return if hooks.empty?
      return if name == :before_first_fork && @before_first_fork_hook_ran
      msg = "Running #{name} hooks"

• Read up
  Read up