parent
2a697c5d1f
commit
0a264c1fe0
1 changed files with 2 additions and 0 deletions
|
|
@ -35,6 +35,8 @@ namespace :migrations do
|
||||||
desc "Migrate sidekiq jobs, retries, scheduled and dead jobs from any legacy queue to "\
|
desc "Migrate sidekiq jobs, retries, scheduled and dead jobs from any legacy queue to "\
|
||||||
"the default queue (retries all dead jobs)"
|
"the default queue (retries all dead jobs)"
|
||||||
task :legacy_queues do
|
task :legacy_queues do
|
||||||
|
Sidekiq.redis = AppConfig.get_redis_options
|
||||||
|
|
||||||
# Push all retries, scheduled and dead jobs to their queues
|
# Push all retries, scheduled and dead jobs to their queues
|
||||||
Sidekiq::RetrySet.new.retry_all
|
Sidekiq::RetrySet.new.retry_all
|
||||||
Sidekiq::DeadSet.new.retry_all
|
Sidekiq::DeadSet.new.retry_all
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue