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)