handle migration error case

kutluhanmetin · Sep 4, 2023 · 82be952 · 82be952
1 parent aa90444
commit 82be952
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/base/commands/migration/stages.go b/base/commands/migration/stages.go
@@ -111,8 +111,12 @@ func (st *Stages) waitForStatus(ctx context.Context, waitInterval time.Duration,
 	timeoutErr := fmt.Errorf("migration could not be completed: reached timeout while reading status: " +
 		"please ensure that you are using Hazelcast's migration cluster distribution and your DMT config points to that cluster")
 	for {
-		if err := ctx.Err(); err != nil && errors.Is(err, context.DeadlineExceeded) {
-			return timeoutErr
+		if err := ctx.Err(); err != nil {
+			if errors.Is(err, context.DeadlineExceeded) {
+				return timeoutErr
+			} else {
+				return fmt.Errorf("migration failed: %w", err)
+			}
 		}
 		s, err := st.readStatus(ctx)
 		if err != nil {