Function Recover

cron/options.go:144–156

Recover returns a new JobDescriptor that will recover from panics.

(logger log.Logger)

// Recover returns a new JobDescriptor that will recover from panics.
func Recover(logger log.Logger) JobOption {
	return func(descriptor *JobDescriptor) {
		innerRun := descriptor.Run
		descriptor.Run = func(ctx context.Context) error {
			defer func() {
				if r := recover(); r != nil {
					logging.WithContext(logger, ctx).Log("msg", "job panicked", "err", r, "stack", debug.Stack())
				}
			}()
			return innerRun(ctx)
		}
	}
}