28 lines
893 B
Ruby
28 lines
893 B
Ruby
class WaitForClusterCreationWorker
|
|
include Sidekiq::Worker
|
|
include ClusterQueue
|
|
|
|
INITIAL_INTERVAL = 2.minutes
|
|
EAGER_INTERVAL = 10.seconds
|
|
TIMEOUT = 20.minutes
|
|
|
|
def perform(cluster_id)
|
|
Gcp::Cluster.find_by_id(cluster_id).try do |cluster|
|
|
Ci::FetchGcpOperationService.new.execute(cluster) do |operation|
|
|
case operation.status
|
|
when 'RUNNING'
|
|
if TIMEOUT < Time.now.utc - operation.start_time.to_time.utc
|
|
return cluster.make_errored!("Cluster creation time exceeds timeout; #{TIMEOUT}")
|
|
end
|
|
|
|
WaitForClusterCreationWorker.perform_in(EAGER_INTERVAL, cluster.id)
|
|
when 'DONE'
|
|
Ci::FinalizeClusterCreationService.new.execute(cluster)
|
|
else
|
|
return cluster.make_errored!("Unexpected operation status; #{operation.status} #{operation.status_message}")
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|