327
ctx context.Context,
328
timerTask *tasks.ActivityTimeoutTask,
330
>
// activity heartbeat timer task is a special snowflake.
331
>
// normal activity timer task on the passive side will be generated by events related to activity in history replicator,
332
>
// and the standby timer processor will only need to verify whether the timer task can be safely throw away.
333
>
//
334
>
// activity heartbeat timer task cannot be handled in the way mentioned above.
335
>
// the reason is, there is no event driving the creation of new activity heartbeat timer.
336
>
// although there will be an task syncing activity from remote, the task is not an event,
337
>
// and cannot attempt to recreate a new activity timer task.
338
>
//
339
>
// the overall solution is to attempt to generate a new activity timer task whenever the
340
>
// task passed in is safe to be throw away.
341
>
actionFn := func(ctx context.Context, wfContext historyi.WorkflowContext, mutableState historyi.MutableState, _ historyi.ReleaseWorkflowContextFunc) (any, error) {
342
>
if !mutableState.IsWorkflowExecutionRunning() {
343
// workflow already finished, no need to process the timer
344
return nil, nil
345
}
346
348
>
349
>
timerSequence := t.getTimerSequence(mutableState)
350
>
updateMutableState := false
351
>
timerSequenceIDs := timerSequence.LoadAndSortActivityTimers()
352
>
if len(timerSequenceIDs) > 0 {
353
timerSequenceID := timerSequenceIDs[0]
354
_, ok := mutableState.GetActivityInfo(timerSequenceID.EventID)