From cb70bf3161e8c0d0055c2309733cc1d629f4068a Mon Sep 17 00:00:00 2001 From: Cyril Galibern Date: Sat, 7 Feb 2026 14:32:26 +0100 Subject: [PATCH] [worker] Log transaction configuration state during worker startup --- worker/worker.go | 1 + 1 file changed, 1 insertion(+) diff --git a/worker/worker.go b/worker/worker.go index 09fc271..dcc3778 100644 --- a/worker/worker.go +++ b/worker/worker.go @@ -82,6 +82,7 @@ var ( func (w *Worker) Run() error { slog.Info(fmt.Sprintf("starting %d runners for queues: %s", w.Runners, strings.Join(w.Queues, ", "))) + slog.Info(fmt.Sprintf("tx enabled: %v", w.WithTx)) ctx, cancel := context.WithCancel(context.Background()) defer cancel() jobC := make(chan []string, w.Runners)