Rename to ClusterProvisionWorker and CreateGkeClusterService.new.execute

2 files changed, 6 insertions, 6 deletions

diff --git a/app/services/ci/create_cluster_service.rb b/app/services/ci/create_cluster_service.rb
index 2fb6df9d669..179dfa0c6bb 100644
--- a/app/services/ci/create_cluster_service.rb
+++ b/app/services/ci/create_cluster_service.rb
@@ -7,7 +7,7 @@ module Ci
         params.merge(user: current_user,
                      status: Gcp::Cluster.statuses[:scheduled],
                      gcp_token: access_token)).tap do |cluster|
-        ClusterCreationWorker.perform_async(cluster.id) if cluster.persisted?
+        ClusterProvisionWorker.perform_async(cluster.id) if cluster.persisted?
       end
     end
   end
diff --git a/app/services/ci/create_gke_cluster_service.rb b/app/services/ci/provision_cluster_service.rb
index 2407de5fc75..3e7e565b361 100644
--- a/app/services/ci/create_gke_cluster_service.rb
+++ b/app/services/ci/provision_cluster_service.rb
@@ -1,5 +1,5 @@
 module Ci
-  class CreateGkeClusterService
+  class ProvisionClusterService
     def execute(cluster)
       api_client =
         GoogleApi::CloudPlatform::Client.new(cluster.gcp_token, nil)
@@ -15,18 +15,18 @@ module Ci
       rescue Google::Apis::ServerError, Google::Apis::ClientError, Google::Apis::AuthorizationError => e
         return cluster.errored!("Failed to request to CloudPlatform; #{e.message}")
       end
-        
+
       unless operation.status == 'RUNNING' || operation.status == 'PENDING'
         return cluster.errored!("Operation status is unexpected; #{operation.status_message}")
       end
 
-      operation_id = api_client.parse_operation_id(operation.self_link)
+      cluster.gcp_operation_id = api_client.parse_operation_id(operation.self_link)
 
-      unless operation_id
+      unless cluster.gcp_operation_id
         return cluster.errored!('Can not find operation_id from self_link')
       end
 
-      if cluster.creating!(operation_id)
+      if cluster.creating
         WaitForClusterCreationWorker.perform_in(
           WaitForClusterCreationWorker::INITIAL_INTERVAL, cluster.id)
       else