From 0f51ffaf1051f964aae70ec99375b369cbf17774 Mon Sep 17 00:00:00 2001 From: Cenk Alti Date: Fri, 2 Oct 2020 16:46:27 +0300 Subject: [PATCH] show log when retrying mysql errors --- internal/table/table.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/table/table.go b/internal/table/table.go index d7a0cdd..7b57df1 100644 --- a/internal/table/table.go +++ b/internal/table/table.go @@ -10,6 +10,7 @@ import ( "time" "github.com/cenkalti/dalga/v3/internal/clock" + "github.com/cenkalti/dalga/v3/internal/log" "github.com/cenkalti/dalga/v3/internal/retry" my "github.com/go-mysql/errors" "github.com/go-sql-driver/mysql" @@ -455,6 +456,7 @@ func withRetries(retryCount int, fn func() error) (err error) { return nil } if dur := mysqlRetryInterval(err); dur > 0 { + log.Println("mysql error:", err.Error(), "sleeping", dur.String(), "before retry") time.Sleep(dur) continue }