Skip to content

Commit

Permalink
is_master_node as classic host tag
Browse files Browse the repository at this point in the history
  • Loading branch information
aboitreaud committed Dec 27, 2024
1 parent bb69b8c commit 029b864
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion pkg/fleet/installer/setup/djm/dataproc.go
Original file line number Diff line number Diff line change
Expand Up @@ -93,7 +93,7 @@ func setupCommonDataprocHostTags(s *common.Setup, metadataClient *metadata.Clien
isMaster = "true"
}
setHostTag(s, "is_master_node", isMaster)
s.Span.SetTag("host_tag."+"is_master_node", isMaster)
s.Span.SetTag("host."+"is_master_node", isMaster)

clusterName, err := metadataClient.InstanceAttributeValueWithContext(ctx, "dataproc-cluster-name")
if err != nil {
Expand Down
2 changes: 1 addition & 1 deletion pkg/fleet/installer/setup/djm/emr.go
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ func setupCommonEmrHostTags(s *common.Setup) (bool, string, error) {

setHostTag(s, "instance_group_id", info.InstanceGroupID)
setHostTag(s, "is_master_node", strconv.FormatBool(info.IsMaster))
s.Span.SetTag("host_tag."+"is_master_node", info.IsMaster)
s.Span.SetTag("host."+"is_master_node", info.IsMaster)

extraInstanceInfoRaw, err := os.ReadFile(filepath.Join(emrInfoPath, "extraInstanceData.json"))
if err != nil {
Expand Down

0 comments on commit 029b864

Please sign in to comment.