diff --git a/storage/sql/sql.go b/storage/sql/sql.go index 2ddccab7..7f20cf9d 100644 --- a/storage/sql/sql.go +++ b/storage/sql/sql.go @@ -71,7 +71,7 @@ var ( err = tx.Commit() if err != nil { - if pqErr, ok := err.(*pq.Error); ok && pqErr.Code == "40001" { + if pqErr, ok := err.(*pq.Error); ok && pqErr.Code.Name() == "serialization_failure" { // serialization error; retry continue }