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)