32 lines
657 B
Ruby
32 lines
657 B
Ruby
# frozen_string_literal: true
|
|
|
|
module Gitlab
|
|
module SidekiqVersioning
|
|
module Worker
|
|
extend ActiveSupport::Concern
|
|
|
|
included do
|
|
version 0
|
|
|
|
attr_writer :job_version
|
|
end
|
|
|
|
class_methods do
|
|
def version(new_version = nil)
|
|
if new_version
|
|
sidekiq_options version: new_version.to_i
|
|
else
|
|
get_sidekiq_options['version']
|
|
end
|
|
end
|
|
end
|
|
|
|
# Version is not set if `new.perform` is called directly,
|
|
# and in that case we fallback to latest version
|
|
def job_version
|
|
@job_version ||= self.class.version
|
|
end
|
|
end
|
|
end
|
|
end
|