Skip to content

Commit ee8deb6

Browse files
committed
Revert "fix: send old and new pipeline trigger measurements (#565)"
This reverts commit 33cf3c7.
1 parent 07f64e9 commit ee8deb6

File tree

2 files changed

+1
-29
lines changed

2 files changed

+1
-29
lines changed

pkg/utils/utils.go

Lines changed: 1 addition & 28 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ const (
2828
RenameEvent string = "Rename"
2929
ExecuteEvent string = "Execute"
3030

31-
pipelineMeasurement = "pipeline.trigger.v1"
31+
pipelineMeasurement = "pipeline.trigger"
3232
)
3333

3434
func IsAuditEvent(eventName string) bool {
@@ -106,33 +106,6 @@ func NewPipelineDataPoint(data PipelineUsageMetricData) *write.Point {
106106
return influxdb2.NewPoint(pipelineMeasurement, tags, fields, time.Now())
107107
}
108108

109-
// DeprecatedNewPipelineDatapoint transforms the information of a pipeline
110-
// triger into an InfluxDB datapoint. This measurement is deprecated and will
111-
// be retired with the new dashboard implementation.
112-
func DeprecatedNewPipelineDatapoint(data PipelineUsageMetricData) *write.Point {
113-
return influxdb2.NewPoint(
114-
"pipeline.trigger",
115-
map[string]string{
116-
"status": data.Status.String(),
117-
"trigger_mode": data.TriggerMode.String(),
118-
},
119-
map[string]any{
120-
"owner_uid": data.OwnerUID,
121-
"owner_type": data.OwnerType,
122-
"user_uid": data.UserUID,
123-
"user_type": data.UserType,
124-
"pipeline_id": data.PipelineID,
125-
"pipeline_uid": data.PipelineUID,
126-
"pipeline_release_id": data.PipelineReleaseID,
127-
"pipeline_release_uid": data.PipelineReleaseUID,
128-
"pipeline_trigger_id": data.PipelineTriggerUID,
129-
"trigger_time": data.TriggerTime,
130-
"compute_time_duration": data.ComputeTimeDuration,
131-
},
132-
time.Now(),
133-
)
134-
}
135-
136109
type ConnectorUsageMetricData struct {
137110
OwnerUID string
138111
OwnerType mgmtPB.OwnerType

pkg/worker/utils.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@ func (w *worker) writeNewDataPoint(ctx context.Context, data utils.PipelineUsage
2020
}
2121

2222
w.influxDBWriteClient.WritePoint(utils.NewPipelineDataPoint(data))
23-
w.influxDBWriteClient.WritePoint(utils.DeprecatedNewPipelineDatapoint(data))
2423

2524
return nil
2625
}

0 commit comments

Comments
 (0)