DEV: Upgrade Sidekiq to 6.4.2
This commit is contained in:
parent
ac68cb20c3
commit
935838adb6
|
@ -433,7 +433,7 @@ GEM
|
||||||
activesupport (>= 3.1)
|
activesupport (>= 3.1)
|
||||||
shoulda-matchers (5.1.0)
|
shoulda-matchers (5.1.0)
|
||||||
activesupport (>= 5.2.0)
|
activesupport (>= 5.2.0)
|
||||||
sidekiq (6.4.1)
|
sidekiq (6.4.2)
|
||||||
connection_pool (>= 2.2.2)
|
connection_pool (>= 2.2.2)
|
||||||
rack (~> 2.0)
|
rack (~> 2.0)
|
||||||
redis (>= 4.2.0)
|
redis (>= 4.2.0)
|
||||||
|
|
|
@ -107,12 +107,13 @@ describe BackupRestore::SystemInterface do
|
||||||
end
|
end
|
||||||
|
|
||||||
context "with Sidekiq workers" do
|
context "with Sidekiq workers" do
|
||||||
before { flush_sidekiq_redis_namespace }
|
after do
|
||||||
after { flush_sidekiq_redis_namespace }
|
flush_sidekiq_redis_namespace
|
||||||
|
end
|
||||||
|
|
||||||
def flush_sidekiq_redis_namespace
|
def flush_sidekiq_redis_namespace
|
||||||
Sidekiq.redis do |redis|
|
Sidekiq.redis do |redis|
|
||||||
redis.scan_each { |key| Discourse.redis.del(key) }
|
redis.scan_each { |key| redis.del(key) }
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -144,7 +145,7 @@ describe BackupRestore::SystemInterface do
|
||||||
run_at: Time.now.to_i,
|
run_at: Time.now.to_i,
|
||||||
payload: Sidekiq.dump_json(payload)
|
payload: Sidekiq.dump_json(payload)
|
||||||
)
|
)
|
||||||
conn.hmset("#{key}:workers", '444', data)
|
conn.hmset("#{key}:work", '444', data)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue