Skip to content

Commit 8ebe17a

Browse files
feat(record-metrics): always emit active flows (#3536)
1 parent f7e5105 commit 8ebe17a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flow/activities/flowable.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -974,10 +974,10 @@ func (a *FlowableActivity) RecordMetricsCritical(ctx context.Context) error {
974974
a.OtelManager.Metrics.WorkloadTotalReplicasGauge.Record(ctx, int64(workloadTotalReplicaCount))
975975
logger.Info("Finished emitting Workload Compute information")
976976
logger.Info("Emitting Active Flow Info", slog.Int("flows", len(activeFlows)))
977+
a.OtelManager.Metrics.ActiveFlowsGauge.Record(ctx, int64(len(activeFlows)))
977978
if activeFlowCount := len(activeFlows); activeFlowCount > 0 {
978979
activeFlowCpuLimit := totalCpuLimit / float64(activeFlowCount)
979980
activeFlowMemoryLimit := totalMemoryLimit / float64(activeFlowCount)
980-
a.OtelManager.Metrics.ActiveFlowsGauge.Record(ctx, int64(activeFlowCount))
981981
if activeFlowCpuLimit > 0 || activeFlowMemoryLimit > 0 {
982982
for _, info := range activeFlows {
983983
ctx := context.WithValue(ctx, internal.FlowMetadataKey, info.toFlowContextMetadata())

0 commit comments

Comments
 (0)