Merge pull request #75 from kbrock/config-engine

Add Settings.ems.ems_workflows.runner
ManageIQ · Mar 29, 2024 · 2135570 · 2135570
2 parents 73f359f + 4516132
commit 2135570
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 3 deletions.
diff --git a/config/settings/development.yml b/config/settings/development.yml
@@ -1,5 +1,6 @@
 :ems:
   :ems_workflows:
+    :runner:
     :runner_options:
       :docker:
         :network: host

diff --git a/lib/manageiq/providers/workflows/engine.rb b/lib/manageiq/providers/workflows/engine.rb
@@ -37,13 +37,26 @@ def self.seedable_classes
           ]
         end
 
+        def self.floe_runner_name
+          if (runner_setting = Settings.ems.ems_workflows.runner.presence)
+            runner_setting
+          elsif MiqEnvironment::Command.is_podified?
+            "kubernetes"
+          elsif MiqEnvironment::Command.is_appliance? || MiqEnvironment::Command.supports_command?("podman")
+            "podman"
+          else
+            "docker"
+          end
+        end
+
         def self.set_floe_runner
           require "miq_environment"
           require "floe"
 
           floe_runner_settings = Settings.ems.ems_workflows.runner_options
 
-          if MiqEnvironment::Command.is_podified?
+          case floe_runner_name
+          when "kubernetes"
             host = ENV.fetch("KUBERNETES_SERVICE_HOST")
             port = ENV.fetch("KUBERNETES_SERVICE_PORT")
 
@@ -56,16 +69,18 @@ def self.set_floe_runner
             }.merge(floe_runner_settings.kubernetes)
 
             Floe.set_runner("docker", "kubernetes", options)
-          elsif MiqEnvironment::Command.is_appliance? || MiqEnvironment::Command.supports_command?("podman")
+          when "podman"
             options = {}
             options["root"] = Rails.root.join("data/containers/storage").to_s if Rails.env.production?
             options.merge!(floe_runner_settings.podman)
 
             Floe.set_runner("docker", "podman", options)
-          else
+          when "docker"
             options = floe_runner_settings.docker.to_hash
 
             Floe.set_runner("docker", "docker", options)
+          else
+            raise "Unknown runner: #{floe_runner_name}. expecting [kubernetes, podman, docker]"
           end
         end
       end