From e1baeab6bc6d06e7990ca86e804073276529a32e Mon Sep 17 00:00:00 2001 From: Adam Grare Date: Fri, 24 Jan 2020 15:27:48 -0500 Subject: [PATCH] Allow Job#queue_signal to take a queue_name Allow Job state transitions to queue a signal on a particular queue_name allowing states to be run by specific workers. --- app/models/job/state_machine.rb | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/app/models/job/state_machine.rb b/app/models/job/state_machine.rb index 9a6aa49238e..3a0e3e9d071 100644 --- a/app/models/job/state_machine.rb +++ b/app/models/job/state_machine.rb @@ -51,7 +51,7 @@ 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", @@ -59,6 +59,7 @@ def queue_signal(*args, priority: MiqQueue::NORMAL_PRIORITY, role: nil, deliver_ :priority => priority, :role => role, :zone => zone, + :queue_name => queue_name, :task_id => guid, :args => args, :deliver_on => deliver_on,