GROUNDWORK-3440: sanitize service names

Author: VladislavSenkevich

connectors/databricks/utils/clusters.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	"fmt"
+	"regexp"
 
 	"github.com/rs/zerolog/log"
 
@@ -18,7 +19,10 @@ func GetClustersServices(databricksClient *client.DatabricksClient, host string)
 
 	services := make([]transit.MonitoredService, 0, len(clusters))
 	for _, cluster := range clusters {
-		service, err := connectors.CreateService(cluster.Name, host)
+		service, err := connectors.CreateService(
+			regexp.MustCompile(`[^a-zA-Z0-9]+`).ReplaceAllString(cluster.Name, "_"),
+			host,
+		)
 		if err != nil {
 			log.Error().Err(err).Str("cluster_name", cluster.Name).Msg("failed to create service")
 			continue

connectors/databricks/utils/jobs.go

@@ -2,6 +2,7 @@ package utils
 
 import (
 	"fmt"
+	"regexp"
 	"slices"
 	"time"
 
@@ -24,6 +25,8 @@ func GetJobsServices(
 	for _, runs := range jobsRuns {
 		if len(runs) > 0 {
 			for _, run := range runs {
+				run.RunName = regexp.MustCompile(`[^a-zA-Z0-9]+`).ReplaceAllString(run.RunName, "_")
+
 				output := run.Status.TerminationDetails.Message
 				status := transit.ServicePending
 				if run.Status.State == "TERMINATED" {