Merge pull request #22614 from agrare/fix_workflows_queue_operations

Fix workflows operations queued on embedded_ansible

(cherry picked from commit e3c3d28)

app/models/manageiq/providers/embedded_ansible/automation_manager/configuration_script_source.rb

@@ -9,6 +9,10 @@ def self.notify_on_provider_interaction?
     true
   end
 
+  private_class_method def self.queue_role
+    "embedded_ansible"
+  end
+
   def sync
     update!(:status => "running")
     transaction do

app/models/manageiq/providers/embedded_ansible/automation_manager/credential.rb

@@ -1,3 +1,7 @@
 class ManageIQ::Providers::EmbeddedAnsible::AutomationManager::Credential < ManageIQ::Providers::EmbeddedAutomationManager::Authentication
   FRIENDLY_NAME = "Embedded Ansible Credential".freeze
+
+  private_class_method def self.queue_role
+    "embedded_ansible"
+  end
 end

app/models/manageiq/providers/embedded_automation_manager/crud_common.rb

@@ -13,7 +13,7 @@ def queue(instance_id, method_name, args, action, auth_user)
         :priority    => MiqQueue::HIGH_PRIORITY,
         :class_name  => name,
         :method_name => method_name,
-        :role        => "embedded_ansible",
+        :role        => queue_role,
         :zone        => nil
       }
       queue_opts[:instance_id] = instance_id if instance_id
@@ -58,6 +58,10 @@ def create_in_provider_queue(manager_id, params, auth_user = nil)
 
     private
 
+    def queue_role
+      nil
+    end
+
     def send_notification(op_type, manager_id, params, success)
       op_arg = params.except(*notification_excludes).collect { |k, v| "#{k}=#{v}" }.join(', ')
       _log.send(success ? :info : :error, "#{name} #{op_type} with parameters: #{op_arg.inspect} #{success ? 'succeeded' : 'failed'}")