diff --git a/pkg/utils/utils.go b/pkg/utils/utils.go index e87c45e20..aac3a3b7d 100644 --- a/pkg/utils/utils.go +++ b/pkg/utils/utils.go @@ -28,7 +28,7 @@ const ( RenameEvent string = "Rename" ExecuteEvent string = "Execute" - pipelineMeasurement = "pipeline.trigger.v1" + pipelineMeasurement = "pipeline.trigger" ) func IsAuditEvent(eventName string) bool { @@ -106,33 +106,6 @@ func NewPipelineDataPoint(data PipelineUsageMetricData) *write.Point { return influxdb2.NewPoint(pipelineMeasurement, tags, fields, time.Now()) } -// DeprecatedNewPipelineDatapoint transforms the information of a pipeline -// triger into an InfluxDB datapoint. This measurement is deprecated and will -// be retired with the new dashboard implementation. -func DeprecatedNewPipelineDatapoint(data PipelineUsageMetricData) *write.Point { - return influxdb2.NewPoint( - "pipeline.trigger", - map[string]string{ - "status": data.Status.String(), - "trigger_mode": data.TriggerMode.String(), - }, - map[string]any{ - "owner_uid": data.OwnerUID, - "owner_type": data.OwnerType, - "user_uid": data.UserUID, - "user_type": data.UserType, - "pipeline_id": data.PipelineID, - "pipeline_uid": data.PipelineUID, - "pipeline_release_id": data.PipelineReleaseID, - "pipeline_release_uid": data.PipelineReleaseUID, - "pipeline_trigger_id": data.PipelineTriggerUID, - "trigger_time": data.TriggerTime, - "compute_time_duration": data.ComputeTimeDuration, - }, - time.Now(), - ) -} - type ConnectorUsageMetricData struct { OwnerUID string OwnerType mgmtPB.OwnerType diff --git a/pkg/worker/utils.go b/pkg/worker/utils.go index c950d9ab3..63bdc7125 100644 --- a/pkg/worker/utils.go +++ b/pkg/worker/utils.go @@ -22,7 +22,6 @@ func (w *worker) writeNewDataPoint(ctx context.Context, data utils.PipelineUsage } w.influxDBWriteClient.WritePoint(utils.NewPipelineDataPoint(data)) - w.influxDBWriteClient.WritePoint(utils.DeprecatedNewPipelineDatapoint(data)) return nil }