mirror of
https://github.com/GlueOps/autoglue.git
synced 2026-02-13 04:40:05 +01:00
@@ -40,7 +40,7 @@ func ClusterBootstrapWorker(db *gorm.DB, jobs *Jobs) archer.WorkerFn {
|
|||||||
var clusters []models.Cluster
|
var clusters []models.Cluster
|
||||||
if err := db.
|
if err := db.
|
||||||
Preload("BastionServer.SshKey").
|
Preload("BastionServer.SshKey").
|
||||||
Where("status = ?", clusterStatusPending).
|
Where("status = ?", clusterStatusProvisioning).
|
||||||
Find(&clusters).Error; err != nil {
|
Find(&clusters).Error; err != nil {
|
||||||
log.Error().Err(err).Msg("[cluster_bootstrap] query clusters failed")
|
log.Error().Err(err).Msg("[cluster_bootstrap] query clusters failed")
|
||||||
return nil, err
|
return nil, err
|
||||||
|
|||||||
@@ -74,8 +74,8 @@ func ClusterSetupWorker(db *gorm.DB, jobs *Jobs) archer.WorkerFn {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
failCount++
|
failCount++
|
||||||
failedIDs = append(failedIDs, c.ID)
|
failedIDs = append(failedIDs, c.ID)
|
||||||
logger.Error().Err(err).Str("output", out).Msg("[cluster_setup] make setup failed")
|
logger.Error().Err(err).Str("output", out).Msg("[cluster_setup] make ping-servers failed")
|
||||||
_ = setClusterStatus(db, c.ID, clusterStatusFailed, fmt.Sprintf("make setup: %v", err))
|
_ = setClusterStatus(db, c.ID, clusterStatusFailed, fmt.Sprintf("make ping-servers: %v", err))
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user