diff --git a/internal/datastore/mysql/migrations/driver.go b/internal/datastore/mysql/migrations/driver.go index 7aa272ea66..8397083b64 100644 --- a/internal/datastore/mysql/migrations/driver.go +++ b/internal/datastore/mysql/migrations/driver.go @@ -50,20 +50,6 @@ func NewMySQLDriverFromDSN(url string, tablePrefix string, credentialsProvider d return nil, fmt.Errorf(errUnableToInstantiate, err) } - if credentialsProvider != nil { - log.Debug().Str("name", credentialsProvider.Name()).Msg("using credentials provider") - // we must transmit the token over the connection, and not a hash - dbConfig.AllowCleartextPasswords = true - // add a before connect callback to trigger the token retrieval from the credentials provider - err := dbConfig.Apply(sqlDriver.BeforeConnect(func(ctx context.Context, config *sqlDriver.Config) error { - config.User, config.Passwd, err = credentialsProvider.Get(ctx, config.Addr, config.User) - return err - })) - if err != nil { - return nil, fmt.Errorf(errUnableToInstantiate, err) - } - } - connector, err := sqlDriver.NewConnector(dbConfig) if err != nil { return nil, fmt.Errorf(errUnableToInstantiate, err)