Update dataproc.go

DataDog · Dec 27, 2024 · bb69b8c · bb69b8c
1 parent d434bec
commit bb69b8c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/fleet/installer/setup/djm/dataproc.go b/pkg/fleet/installer/setup/djm/dataproc.go
@@ -68,6 +68,7 @@ func SetupDataproc(s *common.Setup) error {
 		return fmt.Errorf("failed to set tags: %w", err)
 	}
 	if isMaster == "true" {
+		log.Info("Setting up integrations on resource manager node")
 		setupResourceManager(s, clusterName)
 	}
 	return nil
@@ -81,6 +82,7 @@ func setupCommonDataprocHostTags(s *common.Setup, metadataClient *metadata.Clien
 		return "", "", err
 	}
 	setHostTag(s, "cluster_id", clusterID)
+	setHostTag(s, "dataproc_cluster_id", clusterID)
 
 	dataprocRole, err := metadataClient.InstanceAttributeValueWithContext(ctx, "dataproc-role")
 	if err != nil {