82
ctx context.Context,
83
task *tasks.DeleteHistoryEventTask,
85
>
ctx, cancel := context.WithTimeout(ctx, taskTimeout)
86
>
defer cancel()
87
>
88
>
workflowExecution := &commonpb.WorkflowExecution{
89
>
WorkflowId: task.GetWorkflowID(),
90
>
RunId: task.GetRunID(),
91
>
}
92
>
93
>
if task.ArchetypeID == chasm.UnspecifiedArchetypeID {
94
task.ArchetypeID = chasm.WorkflowArchetypeID
95
}
96
97
>
weContext, release, err := t.cache.GetOrCreateChasmExecution(
timer_queue_task_executor_base.go
98
>
ctx,
99
>
t.shardContext,
100
>
namespace.ID(task.GetNamespaceID()),
101
>
workflowExecution,
102
>
task.ArchetypeID,
103
>
locks.PriorityLow,
104
>
)
105
>
if err != nil {
106
return err
107
}
109
110
// todo if we need add archetype id for loadMutableState
111
>
mutableState, err := loadMutableStateForTimerTask(ctx, t.shardContext, weContext, task, t.metricsHandler, t.logger)
timer_queue_task_executor_base.go
112
>
switch err.(type) {
113
>
case nil:
114
>
if mutableState == nil {
115
return nil
116
}