Change log level for outgoing headers and update job message

streamingfast · Feb 12, 2025 · 147cdb2 · 147cdb2
1 parent 7163df7
commit 147cdb2
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/orchestrator/scheduler/scheduler.go b/orchestrator/scheduler/scheduler.go
@@ -163,7 +163,7 @@ func (s *Scheduler) Update(msg loop.Msg) loop.Cmd {
 	case stage.MsgMergeFinished:
 		s.Stages.MergeCompleted(msg.Unit)
 		if !s.delayedScheduleNextJob {
-			cmds = append(cmds, work.CmdScheduleNextJob("all store completed"))
+			cmds = append(cmds, work.CmdScheduleNextJob("merge finished"))
 		}
 		cmds = append(cmds,
 			s.Stages.CmdTryMerge(msg.Stage),

diff --git a/orchestrator/work/worker.go b/orchestrator/work/worker.go
@@ -317,7 +317,7 @@ const HeaderWorkerID = "x-sf-worker-id"
 const HeaderWorkerKeepAliveDelay = "x-sf-worker-keep-alive-delay"
 
 func (w *RemoteWorker) SetOutgoingHeaders(ctx context.Context) context.Context {
-	w.logger.Info("setting outgoing headers", zap.String("worker_id", w.id), zap.Duration("keep_alive_delay", w.keepAliveDelay))
+	w.logger.Debug("setting outgoing headers", zap.String("worker_id", w.id), zap.Duration("keep_alive_delay", w.keepAliveDelay))
 	ctxWithHeaders := metadata.AppendToOutgoingContext(ctx,
 		HeaderWorkerID, w.id,
 		HeaderWorkerKeepAliveDelay, w.keepAliveDelay.String(),