Skip to content

Commit 4010e66

Browse files
authored
fix(job telemetry): remove deprecated jobtelemetry files (#5915)
1 parent cca702f commit 4010e66

3 files changed

Lines changed: 1 addition & 339 deletions

File tree

pkg/orchestrator/gke/gke_job_orchestrator.go

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -88,18 +88,6 @@ func (g *GKEOrchestrator) SubmitJob(job orchestrator.JobDefinition) error {
8888
return err
8989
}
9090

91-
startTime := time.Now()
92-
var success bool
93-
defer func() {
94-
latencySecs := time.Since(startTime).Seconds()
95-
profile := map[string]string{
96-
"compute_type": job.ComputeType,
97-
"nodes": fmt.Sprintf("%d", job.NumSlices),
98-
}
99-
100-
orchestrator.RecordLocalMetrics(job.WorkloadName, latencySecs, success, profile)
101-
}()
102-
10391
var err error
10492
err = g.initializeJobSubmission(&job)
10593
if err != nil {
@@ -138,7 +126,7 @@ func (g *GKEOrchestrator) SubmitJob(job orchestrator.JobDefinition) error {
138126
}
139127
}
140128
logging.Info("gcluster job submit workflow completed.")
141-
success = true
129+
142130
return nil
143131
}
144132

pkg/orchestrator/jobtelemetry.go

Lines changed: 0 additions & 105 deletions
This file was deleted.

pkg/orchestrator/jobtelemetry_test.go

Lines changed: 0 additions & 221 deletions
This file was deleted.

0 commit comments

Comments
 (0)