266
_ chasm.TaskAttributes,
267
_ *activitypb.HeartbeatTimeoutTask,
269
>
retryState, err := activity.tryReschedule(ctx, true, 0, createHeartbeatTimeoutFailure())
270
>
if err != nil {
271
return err
272
}
273
274
>
metricsHandler, err := activity.enrichMetricsHandler(ctx, metrics.TimerActiveTaskActivityTimeoutScope)
activity_tasks.go
275
>
if err != nil {
276
return err
277
}
278
280
activity.emitOnAttemptTimedOutMetrics(ctx, metricsHandler, enumspb.TIMEOUT_TYPE_HEARTBEAT)
281
return nil
282
}
283
285
>
timeoutType: enumspb.TIMEOUT_TYPE_HEARTBEAT,
286
>
retryState: retryState,
287
>
metricsHandler: metricsHandler,
288
>
fromStatus: activity.GetStatus(),
289
>
})
290
}