Module: Sidekiq::JobUtil

Included in:
Client, Worker::Setter
Defined in:
lib/sidekiq/job_util.rb

Instance Method Summary collapse

Instance Method Details

#normalize_item(item) ⇒ Object

Raises:

  • (ArgumentError) 


31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/sidekiq/job_util.rb', line 31

def normalize_item(item)
  validate(item)

  # merge in the default sidekiq_options for the item's class and/or wrapped element
  # this allows ActiveJobs to control sidekiq_options too.
  defaults = normalized_hash(item["class"])
  defaults = defaults.merge(item["wrapped"].get_sidekiq_options) if item["wrapped"].respond_to?(:get_sidekiq_options)
  item = defaults.merge(item)

  raise(ArgumentError, "Job must include a valid queue name") if item["queue"].nil? || item["queue"] == ""

  item["class"] = item["class"].to_s
  item["queue"] = item["queue"].to_s
  item["jid"] ||= SecureRandom.hex(12)
  item["created_at"] ||= Time.now.to_f

  item
end

#normalized_hash(item_class) ⇒ Object 



50
51
52
53
54
55
56
57
 
# File 'lib/sidekiq/job_util.rb', line 50

def normalized_hash(item_class)
  if item_class.is_a?(Class)
    raise(ArgumentError, "Message must include a Sidekiq::Worker class, not class name: #{item_class.ancestors.inspect}") unless item_class.respond_to?(:get_sidekiq_options)
    item_class.get_sidekiq_options
  else
    Sidekiq.default_worker_options
  end
end

#validate(item) ⇒ Object

These functions encapsulate various job utilities. They must be simple and free from side effects.

Raises:

  • (ArgumentError) 


9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
 
# File 'lib/sidekiq/job_util.rb', line 9

def validate(item)
  raise(ArgumentError, "Job must be a Hash with 'class' and 'args' keys: `#{item}`") unless item.is_a?(Hash) && item.key?("class") && item.key?("args")
  raise(ArgumentError, "Job args must be an Array: `#{item}`") unless item["args"].is_a?(Array)
  raise(ArgumentError, "Job class must be either a Class or String representation of the class name: `#{item}`") unless item["class"].is_a?(Class) || item["class"].is_a?(String)
  raise(ArgumentError, "Job 'at' must be a Numeric timestamp: `#{item}`") if item.key?("at") && !item["at"].is_a?(Numeric)
  raise(ArgumentError, "Job tags must be an Array: `#{item}`") if item["tags"] && !item["tags"].is_a?(Array)

  if Sidekiq.options[:on_complex_arguments] == :raise
    msg = <<~EOM
      Job arguments to #{item["class"]} must be native JSON types, see https://github.com/mperham/sidekiq/wiki/Best-Practices.
      To disable this error, remove `Sidekiq.strict_args!` from your initializer.
    EOM
    raise(ArgumentError, msg) unless json_safe?(item)
  elsif Sidekiq.options[:on_complex_arguments] == :warn
    Sidekiq.logger.warn <<~EOM unless json_safe?(item)
      Job arguments to #{item["class"]} do not serialize to JSON safely. This will raise an error in
      Sidekiq 7.0. See https://github.com/mperham/sidekiq/wiki/Best-Practices or raise an error today
      by calling `Sidekiq.strict_args!` during Sidekiq initialization.
    EOM
  end
end