def init_workers(config)
      @workers = config.build_workers
      @old_workers.each do |running_worker|
        if blocked_worker = @workers.detect { |worker| worker.idle? && worker.queue_key == running_worker[:queue] }
          blocked_worker.wait_for(running_worker[:pid].to_i)
        end
      end
    end
def init_workers(config)
      @workers = config.build_workers
      @old_workers.each do |running_worker|
        if blocked_worker = @workers.detect { |worker| worker.idle? && worker.queue_key == running_worker[:queue] }
          blocked_worker.wait_for(running_worker[:pid].to_i)
        end
      end
    end
Private.