diff options
author | Alessio Caiazza <acaiazza@gitlab.com> | 2017-11-03 13:02:59 +0300 |
---|---|---|
committer | Alessio Caiazza <acaiazza@gitlab.com> | 2017-11-03 13:02:59 +0300 |
commit | 1ca9aaf860e09351a94331020cd43be4af5f2131 (patch) | |
tree | 46f5e2f1b6352eddfe9cbf759421e2bcafd43a82 /app/services | |
parent | 08752e5d742a144ffb1ec7c8e07e7a558774fbfc (diff) | |
parent | 694cfeb7b7288d7d27eca30f808fba421c1f1719 (diff) |
Merge branch 'refactor-clusters' into 38464-k8s-apps
Diffstat (limited to 'app/services')
-rw-r--r-- | app/services/clusters/create_service.rb | 8 | ||||
-rw-r--r-- | app/services/clusters/gcp/finalize_creation_service.rb | 7 |
2 files changed, 5 insertions, 10 deletions
diff --git a/app/services/clusters/create_service.rb b/app/services/clusters/create_service.rb index a1c74566d7a..1d407739b21 100644 --- a/app/services/clusters/create_service.rb +++ b/app/services/clusters/create_service.rb @@ -13,11 +13,7 @@ module Clusters private def create_cluster - Clusters::Cluster.create!( - cluster_params.merge( - projects: [project])) - rescue ActiveRecord::RecordInvalid => e - e.record + Clusters::Cluster.create(cluster_params) end def cluster_params @@ -27,7 +23,7 @@ module Clusters provider[:access_token] = access_token end - @cluster_params = params.merge(user: current_user) + @cluster_params = params.merge(user: current_user, projects: [project]) end end end diff --git a/app/services/clusters/gcp/finalize_creation_service.rb b/app/services/clusters/gcp/finalize_creation_service.rb index 53b13518771..cea56f4e849 100644 --- a/app/services/clusters/gcp/finalize_creation_service.rb +++ b/app/services/clusters/gcp/finalize_creation_service.rb @@ -9,11 +9,9 @@ module Clusters configure_provider configure_kubernetes - provider.make_created! + cluster.save! rescue Google::Apis::ServerError, Google::Apis::ClientError, Google::Apis::AuthorizationError => e provider.make_errored!("Failed to request to CloudPlatform; #{e.message}") - rescue KubeException => e - provider.make_errored!("Failed to request to Kubernetes; #{e.message}") rescue ActiveRecord::RecordInvalid => e provider.make_errored!("Failed to configure GKE Cluster: #{e.message}") end @@ -22,6 +20,7 @@ module Clusters def configure_provider provider.endpoint = gke_cluster.endpoint + provider.status_event = :make_created end def configure_kubernetes @@ -39,7 +38,7 @@ module Clusters 'https://' + gke_cluster.endpoint, Base64.decode64(gke_cluster.master_auth.cluster_ca_certificate), gke_cluster.master_auth.username, - gke_cluster.master_auth.password) + gke_cluster.master_auth.password).execute end def gke_cluster |