diff --git a/core/services/workflows/monitoring.go b/core/services/workflows/monitoring.go index 61161465622..707c8028606 100644 --- a/core/services/workflows/monitoring.go +++ b/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...))