return context when new transaction returns error (#1033)

ConduitIO · May 11, 2023 · b26d260 · b26d260
1 parent 0697903
commit b26d260
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/foundation/database/postgres/db.go b/pkg/foundation/database/postgres/db.go
@@ -121,7 +121,7 @@ func (d *DB) NewTransaction(ctx context.Context, update bool) (database.Transact
 
 	pgxTx, err := d.pool.BeginTx(ctx, pgx.TxOptions{AccessMode: accessMode})
 	if err != nil {
-		return nil, nil, cerrors.Errorf("could not begin transaction: %w", err)
+		return nil, ctx, cerrors.Errorf("could not begin transaction: %w", err)
 	}
 
 	txn := &Txn{