From abcf13b0a39048e34cb3cf331a5e924cd52c03f5 Mon Sep 17 00:00:00 2001 From: Peter Grlica Date: Wed, 14 Oct 2020 15:55:55 +0200 Subject: [PATCH] Return err on tx store fail --- store/rdbms/rdbms.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/store/rdbms/rdbms.go b/store/rdbms/rdbms.go index f18230da0..723cb513c 100644 --- a/store/rdbms/rdbms.go +++ b/store/rdbms/rdbms.go @@ -4,6 +4,9 @@ import ( "context" "database/sql" "fmt" + "strings" + "time" + "github.com/Masterminds/squirrel" "github.com/cortezaproject/corteza-server/pkg/errors" "github.com/cortezaproject/corteza-server/pkg/filter" @@ -15,8 +18,6 @@ import ( "github.com/cortezaproject/corteza-server/store/rdbms/ddl" "github.com/jmoiron/sqlx" "go.uber.org/zap" - "strings" - "time" ) type ( @@ -368,7 +369,7 @@ func tx(ctx context.Context, dbCandidate interface{}, cfg *Config, txOpt *sql.Tx // Start transaction tx, err = db.BeginTxx(ctx, txOpt) if err != nil { - return nil + return err } if lastTaskErr = task(ctx, tx); lastTaskErr == nil {