Sha256: 096642dc4c45cccd2e05dfa89f691589cf8abbb60cc663c4d4b6d375071256a9
Contents?: true
Size: 722 Bytes
Versions: 17
Compression:
Stored size: 722 Bytes
Contents
module CanvasSync::JobUniqueness
module OnConflict
class Reject < Base
valid_for :perform
def call
# TODO Allow this to work on Sidekiq-backed ActiveJob
unless lock_context.is_a?(CanvasSync::JobUniqueness::Compat::Sidekiq::SidekiqLockContext)
CanvasSync::JobUniqueness.logger.error(":reject conflict strategy is not supported for non-Sidekiq-backed jobs")
return
end
kwargs = {}
kwargs[:notify_failure] = false if Sidekiq::DeadSet.instance_method(:kill).arity > 1
sidekiq_message = lock_context.instance_variable_get(:@job_instance)
Sidekiq::DeadSet.new.kill(JSON.dump(sidekiq_message), **kwargs)
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems