[Wf-Diagnostics] use current clustername for emission of usage logs (#…

…6678)

* [Wf-Diagnostics] use current clustername for emission of usage logs

* Update module.go

service/worker/diagnostics/module.go

@@ -34,6 +34,7 @@ import (
 
 	"github.com/uber/cadence/client"
 	"github.com/uber/cadence/common"
+	"github.com/uber/cadence/common/cluster"
 	"github.com/uber/cadence/common/log"
 	"github.com/uber/cadence/common/messaging"
 	"github.com/uber/cadence/common/metrics"
@@ -54,6 +55,7 @@ type dw struct {
 	tallyScope      tally.Scope
 	worker          worker.Worker
 	invariants      []invariant.Invariant
+	clusterMetadata cluster.Metadata
 }
 
 type Params struct {
@@ -64,6 +66,7 @@ type Params struct {
 	Logger          log.Logger
 	TallyScope      tally.Scope
 	Invariants      []invariant.Invariant
+	ClusterMetadata cluster.Metadata
 }
 
 // New creates a new diagnostics workflow.
@@ -76,6 +79,7 @@ func New(params Params) DiagnosticsWorkflow {
 		clientBean:      params.ClientBean,
 		logger:          params.Logger,
 		invariants:      params.Invariants,
+		clusterMetadata: params.ClusterMetadata,
 	}
 }
 

service/worker/diagnostics/parent_workflow.go

@@ -99,6 +99,7 @@ func (w *dw) DiagnosticsStarterWorkflow(ctx workflow.Context, params Diagnostics
 		RunID:                 params.RunID,
 		Identity:              params.Identity,
 		IssueType:             getIssueType(diagWfResult),
+		Environment:           w.clusterMetadata.GetCurrentClusterName(),
 		DiagnosticsWorkflowID: childWfExec.ID,
 		DiagnosticsRunID:      childWfExec.RunID,
 		DiagnosticsStartTime:  childWfStart,

service/worker/service.go

@@ -350,6 +350,7 @@ func (s *Service) startDiagnostics() {
 		ClientBean:      s.GetClientBean(),
 		Logger:          s.GetLogger(),
 		Invariants:      s.params.DiagnosticsInvariants,
+		ClusterMetadata: s.GetClusterMetadata(),
 	}
 	if err := diagnostics.New(params).Start(); err != nil {
 		s.Stop()