* Fixes #1130 Co-authored-by: Felix Kunde <felix-kunde@gmx.de>
This commit is contained in:
parent
d09e418b56
commit
ab95eaa6ef
|
|
@ -696,12 +696,8 @@ func (c *Cluster) syncPreparedDatabases() error {
|
|||
if err := c.initDbConnWithName(preparedDbName); err != nil {
|
||||
return fmt.Errorf("could not init connection to database %s: %v", preparedDbName, err)
|
||||
}
|
||||
defer func() {
|
||||
if err := c.closeDbConn(); err != nil {
|
||||
c.logger.Errorf("could not close database connection: %v", err)
|
||||
}
|
||||
}()
|
||||
|
||||
c.logger.Debugf("syncing prepared database %q", preparedDbName)
|
||||
// now, prepare defined schemas
|
||||
preparedSchemas := preparedDB.PreparedSchemas
|
||||
if len(preparedDB.PreparedSchemas) == 0 {
|
||||
|
|
@ -715,6 +711,10 @@ func (c *Cluster) syncPreparedDatabases() error {
|
|||
if err := c.syncExtensions(preparedDB.Extensions); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := c.closeDbConn(); err != nil {
|
||||
c.logger.Errorf("could not close database connection: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
return nil
|
||||
|
|
|
|||
Loading…
Reference in New Issue