Skip to content

Commit f748d3d

Browse files
committed
lift error
1 parent 8553501 commit f748d3d

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

coderd/database/postgres/postgres.go

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -122,27 +122,29 @@ func Open() (string, func(), error) {
122122
return "", nil, xerrors.Errorf("expire resource: %w", err)
123123
}
124124

125-
pool.MaxWait = 120 * time.Second
125+
pool.MaxWait = 15 * time.Second
126+
var retryErr error
126127
err = pool.Retry(func() error {
127-
db, err := sql.Open("postgres", dbURL)
128-
if err != nil {
129-
return xerrors.Errorf("open postgres: %w", err)
128+
var db *sql.DB
129+
db, retryErr := sql.Open("postgres", dbURL)
130+
if retryErr != nil {
131+
return xerrors.Errorf("open postgres: %w", retryErr)
130132
}
131133
defer db.Close()
132134

133-
err = db.Ping()
134-
if err != nil {
135-
return xerrors.Errorf("ping postgres: %w", err)
135+
retryErr = db.Ping()
136+
if retryErr != nil {
137+
return xerrors.Errorf("ping postgres: %w", retryErr)
136138
}
137-
err = database.MigrateUp(db)
138-
if err != nil {
139-
return xerrors.Errorf("migrate db: %w", err)
139+
retryErr = database.MigrateUp(db)
140+
if retryErr != nil {
141+
return xerrors.Errorf("migrate db: %w", retryErr)
140142
}
141143

142144
return nil
143145
})
144146
if err != nil {
145-
return "", nil, err
147+
return "", nil, retryErr
146148
}
147149
return dbURL, func() {
148150
_ = pool.Purge(resource)

0 commit comments

Comments
 (0)