DEBUG

internal/server/db/query/transaction.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"database/sql"
 	"fmt"
+	"runtime"
 	"strings"
 	"time"
 
@@ -12,6 +13,17 @@ import (
 
 // Transaction executes the given function within a database transaction with a 10s context timeout.
 func Transaction(ctx context.Context, db *sql.DB, f func(context.Context, *sql.Tx) error) error {
+	_, file, no, ok := runtime.Caller(2)
+	if ok && strings.HasSuffix(file, "retry.go") {
+		_, file, no, ok = runtime.Caller(5)
+	}
+	var caller string
+	if ok {
+		caller = fmt.Sprintf("%s:%d", file, no)
+	}
+	start := time.Now()
+	defer func() { logger.Errorf("DBTRANS: took %dms (from %s)", time.Now().Sub(start).Milliseconds(), caller) }()
+
 	ctx, cancel := context.WithTimeout(ctx, time.Second*10)
 	defer cancel()