Sha256: 25247adc13f9b8b9b25f102e0e93d5fffbc447b59d52b34faf01a43c4cc448ed
Contents?: true
Size: 710 Bytes
Versions: 9
Compression:
Stored size: 710 Bytes
Contents
module Maestrano::Connector::Rails
# This class process the push to Connec, it use PushToConnecJob for retrocompatibility
# By using sidekiq-unique-jobs, it makes sure that 2 calls on the same entity, are processed in order
class PushToConnecWorker
include Sidekiq::Worker
sidekiq_options unique: :while_executing, unique_args: :unique_args
def self.unique_args(args)
organization_id = args[0]
entities_hash = args[1]
[organization_id, entities_hash.keys.sort]
end
def perform(organization_id, entities_hash, opts = {})
organization = Organization.find(organization_id)
PushToConnecJob.new.perform(organization, entities_hash, opts)
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems