lint

core/services/workflows/monitoring.go

@@ -60,7 +60,6 @@ type engineMetrics struct {
 	workflowUnregisteredCounter              metric.Int64Counter
 	workflowExecutionRateLimitGlobalCounter  metric.Int64Counter
 	workflowExecutionRateLimitPerUserCounter metric.Int64Counter
-	workflowExecutionLatencyGauge            metric.Int64Gauge // ms
 	workflowStepErrorCounter                 metric.Int64Counter
 	workflowInitializationCounter            metric.Int64Counter
 	engineHeartbeatCounter                   metric.Int64Counter
@@ -114,13 +113,6 @@ func initEngineMonitoringResources() (m *engineMetricLabeler, err error) {
 		return nil, fmt.Errorf("failed to register workflow unregistered counter: %w", err)
 	}
 
-	em.workflowExecutionLatencyGauge, err = beholder.GetMeter().Int64Gauge(
-		"platform_engine_workflow_time",
-		metric.WithUnit("ms"))
-	if err != nil {
-		return nil, fmt.Errorf("failed to register workflow execution latency gauge: %w", err)
-	}
-
 	em.workflowInitializationCounter, err = beholder.GetMeter().Int64Counter("platform_engine_workflow_initializations")
 	if err != nil {
 		return nil, fmt.Errorf("failed to register workflow initialization counter: %w", err)
@@ -246,11 +238,6 @@ func (c engineMetricLabeler) incrementCapabilityInvocationCounter(ctx context.Co
 	c.em.capabilityInvocationCounter.Add(ctx, 1, metric.WithAttributes(otelLabels...))
 }
 
-func (c engineMetricLabeler) updateWorkflowExecutionLatencyGauge(ctx context.Context, val int64) {
-	otelLabels := monutils.KvMapToOtelAttributes(c.Labels)
-	c.em.workflowExecutionLatencyGauge.Record(ctx, val, metric.WithAttributes(otelLabels...))
-}
-
 func (c engineMetricLabeler) incrementTotalWorkflowStepErrorsCounter(ctx context.Context) {
 	otelLabels := monutils.KvMapToOtelAttributes(c.Labels)
 	c.em.workflowStepErrorCounter.Add(ctx, 1, metric.WithAttributes(otelLabels...))