diff --git a/internal/worker/output_uploader.go b/internal/worker/output_uploader.go
index d6112219..c1c4cf73 100644
--- a/internal/worker/output_uploader.go
+++ b/internal/worker/output_uploader.go
@@ -52,8 +52,8 @@ func (ou *OutputUploader) OutputProduced(taskID, filename string) {
 }
 
 func (ou *OutputUploader) Run(ctx context.Context) {
-	log.Info().Msg("output uploader: running")
-	defer log.Info().Msg("output uploader: shutting down")
+	log.Debug().Msg("output uploader: running")
+	defer log.Debug().Msg("output uploader: shutting down")
 
 	wg := sync.WaitGroup{}
 	wg.Add(1)
diff --git a/internal/worker/upstream_buffer.go b/internal/worker/upstream_buffer.go
index 50d7da8e..43e8d353 100644
--- a/internal/worker/upstream_buffer.go
+++ b/internal/worker/upstream_buffer.go
@@ -133,7 +133,7 @@ func (ub *UpstreamBufferDB) Close() error {
 	ub.wg.Wait()
 
 	// Attempt one final flush, if it's fast enough:
-	log.Info().Msg("upstream buffer shutting down, doing one final flush")
+	log.Debug().Msg("upstream buffer shutting down, doing one final flush")
 	flushCtx, ctxCancel := context.WithTimeout(context.Background(), flushOnShutdownTimeout)
 	defer ctxCancel()
 	if err := ub.Flush(flushCtx); err != nil {