Merge f113652 into 82080ea

topfreegames · Jul 9, 2020 · 16b8b68 · 16b8b68
2 parents 82080ea + f113652
commit 16b8b68
Show file tree

Hide file tree

Showing 5 changed files with 20 additions and 13 deletions.
diff --git a/helm/charts/maestro-postgres/templates/maestro-postgres.yaml b/helm/charts/maestro-postgres/templates/maestro-postgres.yaml
@@ -38,6 +38,8 @@ spec:
           value: maestro
         - name: POSTGRES_DB
           value: maestro
+        - name: POSTGRES_HOST_AUTH_METHOD
+          value: trust
         livenessProbe:
           exec:
             command:

diff --git a/helm/charts/maestro/Chart.yaml b/helm/charts/maestro/Chart.yaml
@@ -1,7 +1,7 @@
 name: maestro
 home: https://github.com/topfreegames/maestro
 description: Maestro api and worker
-version: 7.2.2
+version: 9.5.1
 maintainers:
   - name: TFGCo
     email: backend@tfgco.com
diff --git a/metadata/version.go b/metadata/version.go
@@ -8,7 +8,7 @@
 package metadata
 
 //Version of Maestro
-var Version = "9.4.1"
+var Version = "9.5.2"
 
 //KubeVersion is the desired Kubernetes version
 var KubeVersion = "v1.13.9"
diff --git a/watcher/watcher.go b/watcher/watcher.go
@@ -1262,13 +1262,6 @@ func (w *Watcher) EnsureCorrectRooms() error {
 
 	invalidPods := append(incorrectPods, unregisteredPods...)
 
-	if len(invalidPods) <= 0 {
-		// delete invalidRooms key for safety
-		models.RemoveInvalidRoomsKey(w.RedisClient.Trace(ctx), w.MetricsReporter, w.SchedulerName)
-		logger.Debug("no invalid pods to replace")
-		return nil
-	}
-
 	// get operation manager if it exists.
 	// It won't exist if not in a UpdateSchedulerConfig operation
 	operationManager, err := w.getOperation(ctx, logger)
@@ -1289,10 +1282,12 @@ func (w *Watcher) EnsureCorrectRooms() error {
 		invalidPods = incorrectPods
 
 		if status["description"] != models.OpManagerRollingUpdate {
-			err = models.SetInvalidRooms(w.RedisClient.Trace(ctx), w.MetricsReporter, w.SchedulerName, incorrectPodNames)
-			if err != nil {
-				logger.WithError(err).Error("error trying to save invalid rooms to track progress")
-				return err
+			if len(invalidPods) > 0 {
+				err = models.SetInvalidRooms(w.RedisClient.Trace(ctx), w.MetricsReporter, w.SchedulerName, incorrectPodNames)
+				if err != nil {
+					logger.WithError(err).Error("error trying to save invalid rooms to track progress")
+					return err
+				}
 			}
 			err = operationManager.SetDescription(models.OpManagerRollingUpdate)
 			if err != nil {
@@ -1302,6 +1297,13 @@ func (w *Watcher) EnsureCorrectRooms() error {
 		}
 	}
 
+	if len(invalidPods) <= 0 {
+		// delete invalidRooms key for safety
+		models.RemoveInvalidRoomsKey(w.RedisClient.Trace(ctx), w.MetricsReporter, w.SchedulerName)
+		logger.Debug("no invalid pods to replace")
+		return nil
+	}
+
 	// replace invalid pods using rolling strategy
 	timeoutSec := w.Config.GetInt("updateTimeoutSeconds")
 	timeoutDur := time.Duration(timeoutSec) * time.Second

diff --git a/watcher/watcher_test.go b/watcher/watcher_test.go
@@ -494,6 +494,9 @@ var _ = Describe("Watcher", func() {
 				w.Run = false
 			}, mockDb, nil, nil)
 
+			opManager := models.NewOperationManager(configYaml.Name, mockRedisClient, logger)
+			testing.MockGetCurrentOperationKey(opManager, mockRedisClient, nil)
+
 			mockRedisClient.EXPECT().TxPipeline().Return(mockPipeline)
 			mockPipeline.EXPECT().Del(models.GetInvalidRoomsKey(configYaml.Name))
 			mockPipeline.EXPECT().Exec()