342
343
// use the latest time as last heartbeat time
345
>
if activityInfo.StartedTime != nil {
346
>
lastHeartbeat = timestamp.TimeValue(activityInfo.StartedTime)
347
>
}
348
349
>
if !timestamp.TimeValue(activityInfo.LastHeartbeatUpdateTime).IsZero() && activityInfo.LastHeartbeatUpdateTime.AsTime().After(lastHeartbeat) {
timer_sequence.go
350
lastHeartbeat = timestamp.TimeValue(activityInfo.LastHeartbeatUpdateTime)
351
}
352
354
>
355
>
return &TimerSequenceID{
356
>
EventID: activityInfo.ScheduledEventId,
357
>
Timestamp: heartbeatTimeout,
358
>
TimerType: enumspb.TIMEOUT_TYPE_HEARTBEAT,
359
>
TimerCreated: (activityInfo.TimerTaskStatus & TimerTaskStatusCreatedHeartbeat) > 0,
360
>
Attempt: activityInfo.Attempt,
361
>
}
362
}
363