spec/integration/sidekiq61_spec.rb in loga-2.8.0 vs spec/integration/sidekiq61_spec.rb in loga-2.8.1

- old
+ new

@@ -1,5 +1,7 @@ +# frozen_string_literal: true + require 'spec_helper' require 'timecop' require 'fakeredis' dummy_redis_config = ConnectionPool.new(size: 5) { Redis.new } @@ -25,12 +27,12 @@ # https://github.com/mperham/sidekiq/blob/v6.1.2/test/test_actors.rb#L58-L82 Class.new do attr_reader :latest_error, :mutex, :cond def initialize - @mutex = ::Mutex.new - @cond = ::ConditionVariable.new + @mutex = Mutex.new + @cond = ConditionVariable.new end def processor_died(_inst, err) @latest_error = err @@ -44,11 +46,11 @@ def options { concurrency: 3, queues: ['default'], job_logger: Loga::Sidekiq6::JobLogger, - }.tap { |opts| opts[:fetch] = ::Sidekiq::BasicFetch.new(opts) } + }.tap { |opts| opts[:fetch] = Sidekiq::BasicFetch.new(opts) } end end end let(:target) { StringIO.new } @@ -85,10 +87,10 @@ last_element = JSON.parse(Redis.current.lpop('queue:default')) aggregate_failures do expect(last_element['class']).to eq 'MySidekiqWorker' expect(last_element['args']).to eq ['Bob'] - expect(last_element['retry']).to eq true + expect(last_element['retry']).to be true expect(last_element['queue']).to eq 'default' end end def test_log_from_worker(json_line)