diff --git a/app/jobs/scheduled/migrate_upload_scheme.rb b/app/jobs/scheduled/migrate_upload_scheme.rb index 84e1013eaf3..5516c710452 100644 --- a/app/jobs/scheduled/migrate_upload_scheme.rb +++ b/app/jobs/scheduled/migrate_upload_scheme.rb @@ -5,7 +5,7 @@ module Jobs sidekiq_options retry: false def execute(args) - return if !SiteSetting.migrate_to_new_scheme + return unless SiteSetting.migrate_to_new_scheme # clean up failed uploads Upload.where("created_at < ?", 1.hour.ago) @@ -18,11 +18,6 @@ module Jobs # migrate uploads to new scheme problems = Upload.migrate_to_new_scheme(limit: 50) - if problems.length == 0 - # This job is no longer needed skip it from now - SiteSetting.migrate_to_new_scheme = false - end - problems.each do |hash| upload_id = hash[:upload].id Discourse.handle_job_exception(hash[:ex], error_context(args, "Migrating upload id #{upload_id}", upload_id: upload_id))