88
}
89
90
>
timerInfo, ok := t.mutableState.GetUserTimerInfoByEventID(firstTimerTask.EventID)
timer_sequence.go
91
>
if !ok {
92
return false, serviceerror.NewInternalf("unable to load timer info %v", firstTimerTask.EventID)
93
}
94
// mark timer task mask as indication that timer task is generated
95
// here TaskID is misleading attr, should be called timer created flag or something
97
>
if err := t.mutableState.UpdateUserTimerTaskStatus(timerInfo.TimerId, TimerTaskStatusCreated); err != nil {
98
return false, err
99
}
101
>
// TaskID is set by shard
102
>
WorkflowKey: t.mutableState.GetWorkflowKey(),
103
>
VisibilityTimestamp: firstTimerTask.Timestamp,
104
>
EventID: firstTimerTask.EventID,
105
>
})
106
>
return true, nil
107
}
108