Skip to content

Commit b61677e

Browse files
committed
use defer for telemetry
1 parent a5fd4e3 commit b61677e

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

x/cron/keeper/keeper.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ func (k *Keeper) ExecuteReadySchedules(ctx sdk.Context, executionStage types.Exe
7676
err := k.executeSchedule(ctx, schedule)
7777
recordExecutedSchedule(err, schedule)
7878
}
79-
telemetry.ModuleMeasureSince(types.ModuleName, startTime, LabelExecuteReadySchedules)
79+
defer telemetry.ModuleMeasureSince(types.ModuleName, startTime, LabelExecuteReadySchedules)
8080
}
8181

8282
// AddSchedule adds a new schedule to be executed every certain number of blocks, specified in the `period`.
@@ -210,9 +210,9 @@ func (k *Keeper) executeSchedule(ctx sdk.Context, schedule types.Schedule) error
210210
)
211211
return err
212212
}
213-
telemetry.ModuleMeasureSince(types.ModuleName, startTimeContract, LabelExecuteCronContract, schedule.Name, msg.Contract)
213+
defer telemetry.ModuleMeasureSince(types.ModuleName, startTimeContract, LabelExecuteCronContract, schedule.Name, msg.Contract)
214214
}
215-
telemetry.ModuleMeasureSince(types.ModuleName, startTimeSchedule, LabelExecuteCronSchedule, schedule.Name)
215+
defer telemetry.ModuleMeasureSince(types.ModuleName, startTimeSchedule, LabelExecuteCronSchedule, schedule.Name)
216216
// only save state if all the messages in a schedule were executed successfully
217217
writeFn()
218218
return nil

0 commit comments

Comments
 (0)