Skip to content

Commit 090fd0f

Browse files
feat(record-metrics): add a deadline (#3554)
1 parent 7dbc8d1 commit 090fd0f

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

flow/activities/flowable.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -779,7 +779,9 @@ func (a *FlowableActivity) ScheduledTasks(ctx context.Context) error {
779779
return a.SendWALHeartbeat(ctx)
780780
}))()
781781
defer shared.Interval(ctx, 1*time.Minute, wrapWithLog("RecordMetricsCritical", func() error {
782-
return a.RecordMetricsCritical(ctx)
782+
timeoutCtx, cancelFunc := context.WithTimeout(ctx, 50*time.Second)
783+
defer cancelFunc()
784+
return a.RecordMetricsCritical(timeoutCtx)
783785
}))()
784786
defer shared.Interval(ctx, 2*time.Minute, wrapWithLog("RecordMetricsAggregates", func() error {
785787
if enabled, err := internal.PeerDBMetricsRecordAggregatesEnabled(ctx, nil); err == nil && enabled {

0 commit comments

Comments
 (0)