From 842f7c9be60dcf4b65b4419a7c701d03d6824859 Mon Sep 17 00:00:00 2001 From: allanice001 Date: Tue, 16 Dec 2025 00:52:16 +0000 Subject: [PATCH] fix: bugfix jobs Signed-off-by: allanice001 --- internal/bg/cluster_bootstrap.go | 2 +- internal/bg/cluster_setup.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/bg/cluster_bootstrap.go b/internal/bg/cluster_bootstrap.go index 0d5282f..42c5c0a 100644 --- a/internal/bg/cluster_bootstrap.go +++ b/internal/bg/cluster_bootstrap.go @@ -40,7 +40,7 @@ func ClusterBootstrapWorker(db *gorm.DB, jobs *Jobs) archer.WorkerFn { var clusters []models.Cluster if err := db. Preload("BastionServer.SshKey"). - Where("status = ?", clusterStatusPending). + Where("status = ?", clusterStatusProvisioning). Find(&clusters).Error; err != nil { log.Error().Err(err).Msg("[cluster_bootstrap] query clusters failed") return nil, err diff --git a/internal/bg/cluster_setup.go b/internal/bg/cluster_setup.go index 0030577..f2af709 100644 --- a/internal/bg/cluster_setup.go +++ b/internal/bg/cluster_setup.go @@ -74,8 +74,8 @@ func ClusterSetupWorker(db *gorm.DB, jobs *Jobs) archer.WorkerFn { if err != nil { failCount++ failedIDs = append(failedIDs, c.ID) - logger.Error().Err(err).Str("output", out).Msg("[cluster_setup] make setup failed") - _ = setClusterStatus(db, c.ID, clusterStatusFailed, fmt.Sprintf("make setup: %v", err)) + logger.Error().Err(err).Str("output", out).Msg("[cluster_setup] make ping-servers failed") + _ = setClusterStatus(db, c.ID, clusterStatusFailed, fmt.Sprintf("make ping-servers: %v", err)) continue }