Fix connection urls

justwatchcom · Aug 29, 2023 · 8cd377c · 8cd377c
1 parent 1f10a7a
commit 8cd377c
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/job.go b/job.go
@@ -184,9 +184,15 @@ func (j *Job) updateConnections() {
 					}
 
 				} else {
+					connectionName := fmt.Sprintf("%s:%s:%s", parsedU.Project, parsedU.Region, parsedU.Instance)
+					connectionURL, err := parsedU.GetConnectionURL(cloudsqlDriver, connectionName, database)
+					if err != nil {
+						level.Error(j.log).Log("msg", "could not generate connection url", "err", err)
+						continue
+					}
 					newConn := &connection{
 						conn:     nil,
-						url:      conn,
+						url:      connectionURL,
 						driver:   cloudsqlDriver,
 						host:     parsedU.Host,
 						database: database,