fix(pkg): match goroutines start/stop messages log level

scylladb · Jun 22, 2023 · 271bbdb · 271bbdb
1 parent 9b80747
commit 271bbdb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/pkg/generators/generator.go b/pkg/generators/generator.go
@@ -180,7 +180,7 @@ func (g *Generator) start() {
 			case partition.values <- &typedef.ValueWithToken{Token: token, Value: values}:
 				cntEmitted++
 			case <-gCtx.Done():
-				g.logger.Debug("stopping partition key generation loop",
+				g.logger.Info("stopping partition key generation loop",
 					zap.Uint64("keys_created", cntCreated),
 					zap.Uint64("keys_emitted", cntEmitted))
 				return gCtx.Err()

diff --git a/pkg/jobs/jobs.go b/pkg/jobs/jobs.go
@@ -177,7 +177,7 @@ func mutationJob(
 		}
 		select {
 		case <-ctx.Done():
-			logger.Debug("mutation job terminated")
+			logger.Info("mutation job terminated")
 			return nil
 		case hb := <-pump:
 			time.Sleep(hb)
@@ -286,7 +286,7 @@ func warmupJob(
 		}
 		select {
 		case <-ctx.Done():
-			logger.Debug("warmup job terminated")
+			logger.Info("warmup job terminated")
 			return nil
 		default:
 		}