Skip to content

Commit

Permalink
Merge pull request #19764 from agrare/allow_job_queue_signal_to_take_…
Browse files Browse the repository at this point in the history
…queue_name

Allow Job#queue_signal to take a queue_name
  • Loading branch information
Fryguy authored Jan 24, 2020
2 parents c067197 + e1baeab commit ded356b
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion app/models/job/state_machine.rb
Original file line number Diff line number Diff line change
Expand Up @@ -51,14 +51,15 @@ def signal(signal, *args)
end
end

def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_on: nil, server_guid: nil)
def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_on: nil, server_guid: nil, queue_name: nil)
MiqQueue.put(
:class_name => self.class.name,
:method_name => "signal",
:instance_id => id,
:priority => priority,
:role => role,
:zone => zone,
:queue_name => queue_name,
:task_id => guid,
:args => args,
:deliver_on => deliver_on,
Expand Down

0 comments on commit ded356b

Please sign in to comment.