diff --git a/app/models/manageiq/providers/redhat/infra_manager.rb b/app/models/manageiq/providers/redhat/infra_manager.rb
index 0f3b7021a..f8fb8c0d4 100644
--- a/app/models/manageiq/providers/redhat/infra_manager.rb
+++ b/app/models/manageiq/providers/redhat/infra_manager.rb
@@ -1,4 +1,5 @@
 class ManageIQ::Providers::Redhat::InfraManager < ManageIQ::Providers::InfraManager
+  require_nested  :EmsCluster
   require_nested  :EventCatcher
   require_nested  :EventParser
   require_nested  :RefreshWorker
diff --git a/app/models/manageiq/providers/redhat/infra_manager/api_integration.rb b/app/models/manageiq/providers/redhat/infra_manager/api_integration.rb
index 4357fea03..289aaa592 100644
--- a/app/models/manageiq/providers/redhat/infra_manager/api_integration.rb
+++ b/app/models/manageiq/providers/redhat/infra_manager/api_integration.rb
@@ -28,15 +28,8 @@ def use_graph_refresh?
       use_ovirt_sdk? && supported_api_versions.include?('4')
   end
 
-  def connect(options = {})
-    raise "no credentials defined" if missing_credentials?(options[:auth_type])
-    version = options[:version] || highest_allowed_api_version
-    unless options[:skip_supported_api_validation] || supports_the_api_version?(version)
-      raise "version #{version} of the api is not supported by the provider"
-    end
-
-    # Prepare the options to call the method that creates the actual connection:
-    connect_options = {
+  def apply_connection_options_defaults(options)
+    {
       :id         => id,
       :scheme     => options[:scheme] || 'https',
       :server     => options[:ip] || address,
@@ -48,7 +41,17 @@ def connect(options = {})
       :verify_ssl => default_endpoint.verify_ssl,
       :ca_certs   => default_endpoint.certificate_authority
     }
+  end
 
+  def connect(options = {})
+    raise "no credentials defined" if missing_credentials?(options[:auth_type])
+    version = options[:version] || highest_allowed_api_version
+    unless options[:skip_supported_api_validation] || supports_the_api_version?(version)
+      raise "version #{version} of the api is not supported by the provider"
+    end
+
+    # Prepare the options to call the method that creates the actual connection:
+    connect_options = apply_connection_options_defaults(options)
     # Starting with version 4 of oVirt authentication doesn't work when using directly the IP address, it requires
     # the fully qualified host name, so if we received an IP address we try to convert it into the corresponding
     # host name:
diff --git a/app/models/manageiq/providers/redhat/infra_manager/ems_cluster.rb b/app/models/manageiq/providers/redhat/infra_manager/ems_cluster.rb
new file mode 100644
index 000000000..221db779e
--- /dev/null
+++ b/app/models/manageiq/providers/redhat/infra_manager/ems_cluster.rb
@@ -0,0 +1,29 @@
+class ManageIQ::Providers::Redhat::InfraManager::EmsCluster < ::EmsCluster
+  def upgrade(options = {})
+    role_options = {:role_name => "oVirt.cluster-upgrade"}
+    job = ManageIQ::Providers::AnsibleRoleWorkflow.create_job({}, extra_vars_for_upgrade(options), role_options)
+    job.signal(:start)
+    job.miq_task
+  end
+
+  private
+
+  def extra_vars_for_upgrade(options = {})
+    connect_options = ext_management_system.apply_connection_options_defaults(options)
+
+    url = URI::Generic.build(
+      :scheme => connect_options[:scheme],
+      :host   => connect_options[:server],
+      :port   => connect_options[:port],
+      :path   => connect_options[:path]
+    ).to_s
+
+    {
+      :engine_url      => url,
+      :engine_user     => connect_options[:username],
+      :engine_password => connect_options[:password],
+      :cluster_name    => name,
+      :hostname        => "localhost"
+    }
+  end
+end
diff --git a/app/models/manageiq/providers/redhat/inventory/persister/definitions/infra_collections.rb b/app/models/manageiq/providers/redhat/inventory/persister/definitions/infra_collections.rb
index c8c840aaf..843e5e3ec 100644
--- a/app/models/manageiq/providers/redhat/inventory/persister/definitions/infra_collections.rb
+++ b/app/models/manageiq/providers/redhat/inventory/persister/definitions/infra_collections.rb
@@ -24,7 +24,9 @@ def initialize_infra_inventory_collections
   # --- IC groups definitions ---
 
   def add_clusters_group
-    add_collection(infra, :ems_clusters)
+    add_collection(infra, :ems_clusters) do |builder|
+      builder.add_properties(:model_class => ::EmsCluster)
+    end
     add_resource_pools
   end
 
diff --git a/spec/factories/ems_cluster.rb b/spec/factories/ems_cluster.rb
new file mode 100644
index 000000000..32bbb074b
--- /dev/null
+++ b/spec/factories/ems_cluster.rb
@@ -0,0 +1,3 @@
+FactoryGirl.define do
+  factory :ems_cluster_redhat, :class => "ManageIQ::Providers::Redhat::InfraManager::EmsCluster", :parent => :ems_cluster
+end
diff --git a/spec/models/manageiq/providers/redhat/infra_manager/ems_cluster_spec.rb b/spec/models/manageiq/providers/redhat/infra_manager/ems_cluster_spec.rb
new file mode 100644
index 000000000..fdc83724d
--- /dev/null
+++ b/spec/models/manageiq/providers/redhat/infra_manager/ems_cluster_spec.rb
@@ -0,0 +1,21 @@
+describe ManageIQ::Providers::Redhat::InfraManager::EmsCluster do
+  context "#upgrade" do
+    before do
+      @ems = FactoryGirl.create(:ems_redhat_with_authentication)
+      @cluster = FactoryGirl.create(:ems_cluster_redhat, :ems_id => @ems.id)
+      my_server = double("my_server", :guid => "guid1")
+      allow(MiqServer).to receive(:my_server).and_return(my_server)
+    end
+    it "sends the right parameters to the upgrade" do
+      env_vars = {}
+      extra_args = {:engine_url      => "https://#{@ems.address}/ovirt-engine/api",
+                    :engine_user     => @ems.authentication_userid,
+                    :engine_password => @ems.authentication_password,
+                    :cluster_name    => @cluster.name,
+                    :hostname        => "localhost"}
+      role_arg = {:role_name=>"oVirt.cluster-upgrade"}
+      expect(ManageIQ::Providers::AnsibleRoleWorkflow).to receive(:create_job).with(env_vars, extra_args, role_arg).and_call_original
+      @cluster.upgrade
+    end
+  end
+end