Merge pull request #21414 from agrare/handle_ansible_runner_exceptions

Handle ansible runner exceptions in the AnsibleRunnerWorkflow

app/models/manageiq/providers/ansible_runner_workflow.rb

@@ -50,6 +50,8 @@ def execute
 
       route_signal(:poll_runner)
     end
+  rescue => err
+    route_signal(:abort, "Failed to run ansible #{execution_type}: #{err}", "error")
   end
 
   def poll_runner

lib/ansible/runner.rb

@@ -371,7 +371,15 @@ def wait_for(path, timeout: 10.seconds)
           path_created.set if added.include?(path) || modified.include?(path)
         end
 
-        thread = Thread.new { listener.start }
+        thread = Thread.new do
+          listener.start
+        rescue ArgumentError => err
+          # If the main thread raises an exception immediately it is possible
+          # for the ensure block to call `listener.stop` before this thread
+          # begins its execution resulting in an ArgumentError due to the state
+          # being `:stopped`
+          raise unless err.message.include?("cannot start from state :stopped")
+        end
 
         begin
           res = yield